dbos-inc/agent-skills

func fetchData(ctx context.Context) (string, error) { 	resp, err := http.Get("https://api.example.com/data")

resp, err := http.Get("https://api.example.com/data")

- https://docs.dbos.dev/

- https://github.com/dbos-inc/dbos-transact-golang

Reference: [Application versions](https://docs.dbos.dev/golang/tutorials/workflow-management)

Reference: [DBOS Cross-Language Workflows](https://docs.dbos.dev/)

[Credential-related source omitted]

Reference: [Patching](https://docs.dbos.dev/golang/tutorials/upgrading-workflows#patching), [DBOS Transact Enterprise](https://docs.dbos.dev/explanations/transact-enterprise)

Reference: [DBOS Configuration](https://docs.dbos.dev/golang/reference/configuration)

Reference: [Sharing a System Database](https://docs.dbos.dev/explanations/sharing-a-system-database)

Reference: [Versioning](https://docs.dbos.dev/golang/tutorials/upgrading-workflows#versioning)

Reference: [DBOS Client Enqueue](https://docs.dbos.dev/golang/reference/client#enqueue)

Reference: [DBOS Client](https://docs.dbos.dev/golang/reference/client)

Reference: [Workflow Events](https://docs.dbos.dev/golang/tutorials/workflow-communication#workflow-events)

Reference: [Workflow Messaging and Notifications](https://docs.dbos.dev/golang/tutorials/workflow-communication#workflow-messaging-and-notifications)

Reference: [Workflow Streaming](https://docs.dbos.dev/golang/tutorials/workflow-communication#workflow-streaming)

[Credential-related source omitted]

Reference: [Integrating DBOS](https://docs.dbos.dev/golang/integrating-dbos), [DBOS Transact Enterprise](https://docs.dbos.dev/explanations/transact-enterprise)

Reference: [Debouncing Workflows](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#debouncing)

Reference: [Queues](https://docs.dbos.dev/golang/tutorials/queue-tutorial)

Reference: [Workflow IDs and Idempotency](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#workflow-ids-and-idempotency)

Reference: [Scheduled Workflows](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#scheduled-workflows)

Reference: [Durable Sleep](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#durable-sleep)

Reference: [DBOS Queues](https://docs.dbos.dev/golang/tutorials/queue-tutorial)

Reference: [Managing Concurrency](https://docs.dbos.dev/golang/tutorials/queue-tutorial#managing-concurrency)

Reference: [Deduplication](https://docs.dbos.dev/golang/tutorials/queue-tutorial#deduplication)

Reference: [Listening to Specific Queues](https://docs.dbos.dev/golang/tutorials/queue-tutorial#listening-to-specific-queues)

Reference: [Partitioning Queues](https://docs.dbos.dev/golang/tutorials/queue-tutorial#partitioning-queues)

Reference: [Priority](https://docs.dbos.dev/golang/tutorials/queue-tutorial#priority)

Reference: [Rate Limiting](https://docs.dbos.dev/golang/tutorials/queue-tutorial#rate-limiting)

func myWorkflow(ctx dbos.Context, input string) (string, error) { 	// External API call directly in workflow - not checkpointed! 	resp, err := http.Get("https://api.example.com/data")

// External API call directly in workflow - not checkpointed! 	resp, err := http.Get("https://api.example.com/data") 	if err != nil {

resp, err := http.Get("https://api.example.com/data")

func fetchData(ctx context.Context) (string, error) { 	resp, err := http.Get("https://api.example.com/data")

resp, err := http.Get("https://api.example.com/data")

func myWorkflow(ctx dbos.Context, input string) (string, error) { 	data, err := dbos.RunAsStep(ctx, func(ctx context.Context) (string, error) { 		resp, err := http.Get("https://api.example.com/data")

data, err := dbos.RunAsStep(ctx, func(ctx context.Context) (string, error) { 		resp, err := http.Get("https://api.example.com/data") 		if err != nil {

resp, err := http.Get("https://api.example.com/data")

Reference: [DBOS Steps](https://docs.dbos.dev/golang/tutorials/step-tutorial)

Reference: [Concurrent Steps](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#concurrent-steps)

var lastErr error 	for attempt := 0; attempt < 3; attempt++ { 		resp, err := http.Get("https://api.example.com")

for attempt := 0; attempt < 3; attempt++ { 		resp, err := http.Get("https://api.example.com") 		if err == nil {

resp, err := http.Get("https://api.example.com")

func fetchData(ctx context.Context) (string, error) { 	resp, err := http.Get("https://api.example.com")

resp, err := http.Get("https://api.example.com")

Reference: [Configurable Retries](https://docs.dbos.dev/golang/tutorials/step-tutorial#configurable-retries)

Reference: [Transactions & Datasources](https://docs.dbos.dev/golang/tutorials/transaction-tutorial)

Reference: [Testing DBOS](https://docs.dbos.dev/golang/tutorials/testing)

Reference: [Workflow Management](https://docs.dbos.dev/golang/tutorials/workflow-management)

Reference: [Workflow Management](https://docs.dbos.dev/golang/tutorials/workflow-management)

Reference: [Workflows](https://docs.dbos.dev/golang/tutorials/workflow-tutorial)

func fetchData(ctx context.Context) (string, error) { 	// Steps only do external operations 	resp, err := http.Get("https://api.example.com")

// Steps only do external operations 	resp, err := http.Get("https://api.example.com") 	if err != nil {

resp, err := http.Get("https://api.example.com")

Reference: [Workflow Guarantees](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#workflow-guarantees)

Reference: [Workflow Management](https://docs.dbos.dev/golang/tutorials/workflow-management)

Reference: [Workflow Determinism](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#determinism)

Reference: [Workflow Registration](https://docs.dbos.dev/golang/reference/workflows-steps#withinstance)

Reference: [Workflow Management](https://docs.dbos.dev/golang/tutorials/workflow-management#listing-workflows)

Reference: [Workflow Timeouts](https://docs.dbos.dev/golang/tutorials/workflow-tutorial#workflow-timeouts)

- https://docs.dbos.dev/

- https://github.com/dbos-inc/dbos-transact-java

Reference: [Serialization Strategy](https://docs.dbos.dev/java/reference/methods#serialization-strategy)

Reference: [Using DBOS with Kotlin](https://docs.dbos.dev/java/tutorials/kotlin)

Reference: [Patching](https://docs.dbos.dev/java/tutorials/upgrading-workflows#patching)

Reference: [Custom Serialization](https://docs.dbos.dev/java/reference/lifecycle#custom-serialization)

Reference: [Sharing a System Database](https://docs.dbos.dev/explanations/sharing-a-system-database)

Reference: [Upgrading Workflow Code](https://docs.dbos.dev/java/tutorials/upgrading-workflows#versioning)

Reference: [enqueueWorkflow](https://docs.dbos.dev/java/reference/client#enqueueworkflow)

Reference: [DBOS Client](https://docs.dbos.dev/java/reference/client)

Reference: [Workflow Events](https://docs.dbos.dev/java/tutorials/workflow-communication#workflow-events)

Reference: [Workflow Messaging](https://docs.dbos.dev/java/tutorials/workflow-communication#workflow-messaging-and-notifications)

Reference: [writeStream / readStream](https://docs.dbos.dev/java/reference/methods#writestream)

Reference: [DBOS Lifecycle](https://docs.dbos.dev/java/reference/lifecycle)

Reference: [Spring Boot Integration](https://docs.dbos.dev/java/tutorials/spring-boot-integration)

Reference: [Debouncing](https://docs.dbos.dev/java/reference/methods#debouncing)

Reference: [Workflow IDs and Idempotency](https://docs.dbos.dev/java/tutorials/workflow-tutorial#workflow-ids-and-idempotency)

Reference: [Scheduled Workflows](https://docs.dbos.dev/java/tutorials/scheduled-workflows)

Reference: [Durable Sleep](https://docs.dbos.dev/java/tutorials/workflow-tutorial#durable-sleep)

Reference: [DBOS Queues](https://docs.dbos.dev/java/tutorials/queue-tutorial)

Reference: [Managing Concurrency](https://docs.dbos.dev/java/tutorials/queue-tutorial#managing-concurrency)

Reference: [Deduplication](https://docs.dbos.dev/java/tutorials/queue-tutorial#deduplication)

Reference: [Delaying Execution](https://docs.dbos.dev/java/tutorials/queue-tutorial#delaying-execution)

Reference: [Explicit Queue Listening](https://docs.dbos.dev/java/tutorials/queue-tutorial#explicit-queue-listening)

Reference: [Reconfiguring Queues at Runtime](https://docs.dbos.dev/java/tutorials/queue-tutorial#reconfiguring-queues-at-runtime)

Reference: [Partitioning Queues](https://docs.dbos.dev/java/tutorials/queue-tutorial#partitioning-queues)

Reference: [Priority](https://docs.dbos.dev/java/tutorials/queue-tutorial#priority)

Reference: [Rate Limiting](https://docs.dbos.dev/java/tutorials/queue-tutorial#rate-limiting)

public String myWorkflow(String url) throws Exception {     // Inline lambda step     String body = dbos.runStep(() -> fetch(url), "fetch");

// Inline lambda step     String body = dbos.runStep(() -> fetch(url), "fetch");     // Reusable @Step method — invoked through the proxy so it is checkpointed

String body = dbos.runStep(() -> fetch(url), "fetch");

private String fetch(String url) throws Exception {

Reference: [DBOS Steps](https://docs.dbos.dev/java/tutorials/step-tutorial)

for (int attempt = 0; attempt < 5; attempt++) {     try {       return dbos.runStep(() -> fetch(url), "fetch");

try {       return dbos.runStep(() -> fetch(url), "fetch");     } catch (Exception e) {

return dbos.runStep(() -> fetch(url), "fetch");

public String fetchWorkflow(String url) throws Exception {   return dbos.runStep(       () -> fetch(url),

return dbos.runStep(       () -> fetch(url),       new StepOptions("fetch")

() -> fetch(url),

@Step(name = "fetch", maxAttempts = 10, intervalSeconds = 0.5, backOffRate = 2.0) public String fetch(String url) throws Exception { /* ... */ }

public String fetch(String url) throws Exception { /* ... */ }

// Lambda form dbos.runStep(() -> fetch(url),

dbos.runStep(() -> fetch(url),

Reference: [Configurable Retries](https://docs.dbos.dev/java/tutorials/step-tutorial#configurable-retries)

Reference: [Transactional Steps](https://docs.dbos.dev/java/tutorials/step-factory-tutorial)

Reference: [Testing Workflows](https://docs.dbos.dev/java/tutorials/testing)

Reference: [Starting Workflows in the Background](https://docs.dbos.dev/java/tutorials/workflow-tutorial#starting-workflows-in-the-background)

Reference: [Workflow Tutorial](https://docs.dbos.dev/java/tutorials/workflow-tutorial)

Reference: [Workflow Management](https://docs.dbos.dev/java/tutorials/workflow-management)

Reference: [Workflow Determinism](https://docs.dbos.dev/java/tutorials/workflow-tutorial#determinism)

// Both registrations use the default instance name — DBOS cannot tell them // apart during recovery, and workflows may resume on the wrong configuration dbos.registerProxy(DataProcessor.class, new DataProcessorImpl("https://service-a.examp

// apart during recovery, and workflows may resume on the wrong configuration dbos.registerProxy(DataProcessor.class, new DataProcessorImpl("https://service-a.example.com")); dbos.registerProxy(DataProcessor.class, new DataProcessorImpl("ht

dbos.registerProxy(DataProcessor.class, new DataProcessorImpl("https://service-a.example.com"));

dbos.registerProxy(DataProcessor.class, new DataProcessorImpl("https://service-b.example.com"));

DataProcessor processorA = dbos.registerProxy(     DataProcessor.class,     new DataProcessorImpl("https://service-a.example.com"),

DataProcessor.class,     new DataProcessorImpl("https://service-a.example.com"),     "service-a");

new DataProcessorImpl("https://service-a.example.com"),

DataProcessor processorB = dbos.registerProxy(     DataProcessor.class,     new DataProcessorImpl("https://service-b.example.com"),

DataProcessor.class,     new DataProcessorImpl("https://service-b.example.com"),     "service-b");

new DataProcessorImpl("https://service-b.example.com"),

Reference: [Workflows on Class Instances](https://docs.dbos.dev/java/tutorials/workflow-classes)

Reference: [Workflow Management Methods](https://docs.dbos.dev/java/reference/methods#workflow-management-methods)

Reference: [Workflows & Steps](https://docs.dbos.dev/java/reference/workflows-steps)

Reference: [Workflow Timeouts](https://docs.dbos.dev/java/tutorials/workflow-tutorial#workflow-timeouts)

[Credential-related source omitted]

@DBOS.step() def call_external_api():     return requests.get("https://api.example.com").json()

return requests.get("https://api.example.com").json()

- https://docs.dbos.dev/

- https://github.com/dbos-inc/dbos-transact-py

@DBOS.step() async def fetch_async():     async with aiohttp.ClientSession() as session:

async def fetch_async():     async with aiohttp.ClientSession() as session:         async with session.get("https://example.com") as response:

async with aiohttp.ClientSession() as session:

async with session.get("https://example.com") as response:

def fetch(arg):  # plain function, run as a step through its reservation

[Credential-related source omitted]

Reference: [Async Workflows](https://docs.dbos.dev/python/tutorials/workflow-tutorial#coroutine-async-workflows)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Reference: [Patching](https://docs.dbos.dev/python/tutorials/upgrading-workflows#patching), [Auto-Upgrading Workflows](https://docs.dbos.dev/python/tutorials/upgrading-workflows#auto-upgrading-workflows)

Reference: [Cross-Language Interaction](https://docs.dbos.dev/explanations/portable-workflows)

[Credential-related source omitted]

Reference: [Sharing a System Database](https://docs.dbos.dev/explanations/sharing-a-system-database)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Reference: [Upgrading to 3.0](https://docs.dbos.dev/python/upgrading)

Reference: [Versioning](https://docs.dbos.dev/python/tutorials/upgrading-workflows#versioning)

"workflow_name": "URLFetcher.fetch_workflow",     "class_name": "URLFetcher",     "instance_name": "https://example.com",

"class_name": "URLFetcher",     "instance_name": "https://example.com", }

"instance_name": "https://example.com",

[Credential-related source omitted]

[Credential-related source omitted]

Reference: [DBOSClient.enqueue](https://docs.dbos.dev/python/reference/client#enqueue)

[Credential-related source omitted]

Reference: [DBOSClient](https://docs.dbos.dev/python/reference/client)

Reference: [Workflow Events](https://docs.dbos.dev/python/tutorials/workflow-communication#workflow-events)

Reference: [Workflow Messaging](https://docs.dbos.dev/python/tutorials/workflow-communication#workflow-messaging-and-notifications)

Reference: [Workflow Streaming](https://docs.dbos.dev/python/tutorials/workflow-communication#workflow-streaming)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Reference: [DBOS Configuration](https://docs.dbos.dev/python/reference/configuration)

[Credential-related source omitted]

[Credential-related source omitted]

Reference: [DBOS with FastAPI](https://docs.dbos.dev/python/tutorials/workflow-tutorial)

@DBOS.workflow()  # Won't work without proper setup     def fetch_data(self):         return self.fetch()

return self.fetch()

@DBOS.step()     def fetch_url(self):         return requests.get(self.url).text

return requests.get(self.url).text

# Instantiate BEFORE DBOS.launch() example_fetcher = URLFetcher("https://example.com")

example_fetcher = URLFetcher("https://example.com")

api_fetcher = URLFetcher("https://api.example.com")

[Credential-related source omitted]

Reference: [Python Classes](https://docs.dbos.dev/python/tutorials/classes)

Reference: [Debouncing Workflows](https://docs.dbos.dev/python/tutorials/workflow-tutorial#debouncing-workflows)

Reference: [Workflow IDs and Idempotency](https://docs.dbos.dev/python/tutorials/workflow-tutorial#workflow-ids-and-idempotency)

DBOS parses schedules with [croniter](https://pypi.org/project/croniter/) (with `second_at_beginning` enabled), so they follow croniter's syntax and semantics, with seconds as an optional first field:

Reference: [Scheduling Workflows](https://docs.dbos.dev/python/tutorials/scheduled-workflows)

Reference: [Durable Sleep](https://docs.dbos.dev/python/tutorials/workflow-tutorial#durable-sleep)

Reference: [DBOS Queues](https://docs.dbos.dev/python/tutorials/queue-tutorial)

Reference: [Managing Concurrency](https://docs.dbos.dev/python/tutorials/queue-tutorial#managing-concurrency)

Reference: [Queue Deduplication](https://docs.dbos.dev/python/tutorials/queue-tutorial#deduplication)

Reference: [Delayed Execution](https://docs.dbos.dev/python/tutorials/queue-tutorial#delayed-execution)

[Credential-related source omitted]

Reference: [Explicit Queue Listening](https://docs.dbos.dev/python/tutorials/queue-tutorial#explicit-queue-listening)

Reference: [Queues Reference](https://docs.dbos.dev/python/reference/queues)

Reference: [Partitioning Queues](https://docs.dbos.dev/python/tutorials/queue-tutorial#partitioning-queues)

Reference: [Rate Limiting](https://docs.dbos.dev/python/tutorials/queue-tutorial#rate-limiting)

def my_workflow():     # External API call directly in workflow - not checkpointed!     response = requests.get("https://api.example.com/data")

# External API call directly in workflow - not checkpointed!     response = requests.get("https://api.example.com/data")     return response.json()

response = requests.get("https://api.example.com/data")

@DBOS.step() def fetch_data():     response = requests.get("https://api.example.com/data")

def fetch_data():     response = requests.get("https://api.example.com/data")     return response.json()

response = requests.get("https://api.example.com/data")

Reference: [DBOS Steps](https://docs.dbos.dev/python/tutorials/step-tutorial)

for attempt in range(3):         try:             return requests.get("https://api.example.com").json()

try:             return requests.get("https://api.example.com").json()         except Exception:

return requests.get("https://api.example.com").json()

def fetch_data():     # Retries handled automatically     return requests.get("https://api.example.com").json()

return requests.get("https://api.example.com").json()

@DBOS.step(retries_allowed=True, max_attempts=10) def fetch_user(user_id: str):     response = requests.get(f"https://api.example.com/users/{user_id}")

def fetch_user(user_id: str):     response = requests.get(f"https://api.example.com/users/{user_id}")     response.raise_for_status()  # 404 will retry 10 times before giving up

response = requests.get(f"https://api.example.com/users/{user_id}")

) def fetch_user(user_id: str):     response = requests.get(f"https://api.example.com/users/{user_id}")

def fetch_user(user_id: str):     response = requests.get(f"https://api.example.com/users/{user_id}")     response.raise_for_status()

response = requests.get(f"https://api.example.com/users/{user_id}")

@DBOS.step(timeout_seconds=30)  # Raises: Python can't preempt a running sync function def fetch_data():     return requests.get("https://example.com").text

return requests.get("https://example.com").text

@DBOS.step(timeout_seconds=30, retries_allowed=True, max_attempts=3) async def fetch_data():     async with aiohttp.ClientSession() as session:

async def fetch_data():     async with aiohttp.ClientSession() as session:         async with session.get("https://example.com") as response:

async with aiohttp.ClientSession() as session:

async with session.get("https://example.com") as response:

Reference: [Configurable Retries](https://docs.dbos.dev/python/tutorials/step-tutorial#configurable-retries)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Reference: [Transactions & Datasources](https://docs.dbos.dev/python/tutorials/transaction-tutorial)

[Credential-related source omitted]

Reference: [Testing DBOS](https://docs.dbos.dev/python/tutorials/testing)

Reference: [Workflow Attributes](https://docs.dbos.dev/python/tutorials/workflow-management#workflow-attributes)

Reference: [Starting Workflows](https://docs.dbos.dev/python/tutorials/workflow-tutorial#starting-workflows-in-the-background)

Reference: [DBOS Workflows](https://docs.dbos.dev/python/tutorials/workflow-tutorial)

Reference: [Workflow Management](https://docs.dbos.dev/python/tutorials/workflow-management)

Reference: [Workflow Determinism](https://docs.dbos.dev/python/tutorials/workflow-tutorial#determinism)

Reference: [Workflow Management](https://docs.dbos.dev/python/tutorials/workflow-management)

Reference: [Workflow Timeouts](https://docs.dbos.dev/python/tutorials/workflow-tutorial#workflow-timeouts)

async function fetchData() {   return await fetch("https://api.example.com").then(r => r.json());

return await fetch("https://api.example.com").then(r => r.json());

- https://docs.dbos.dev/

- https://github.com/dbos-inc/dbos-transact-ts

[Credential-related source omitted]

Reference: [Patching](https://docs.dbos.dev/typescript/tutorials/upgrading-workflows#patching), [Auto-Upgrading Workflows](https://docs.dbos.dev/typescript/tutorials/upgrading-workflows#auto-upgrading-workflows)

Reference: [Cross-Language Interaction](https://docs.dbos.dev/explanations/portable-workflows)

Reference: [Sharing a System Database](https://docs.dbos.dev/explanations/sharing-a-system-database)

Reference: [Upgrading to 5.0](https://docs.dbos.dev/typescript/upgrading)

Reference: [Versioning](https://docs.dbos.dev/typescript/tutorials/upgrading-workflows#versioning)

Reference: [DBOS Client Enqueue](https://docs.dbos.dev/typescript/reference/client#enqueue)

Reference: [DBOS Client](https://docs.dbos.dev/typescript/reference/client)

Reference: [Workflow Events](https://docs.dbos.dev/typescript/tutorials/workflow-communication#workflow-events)

Reference: [Workflow Messaging](https://docs.dbos.dev/typescript/tutorials/workflow-communication#workflow-messaging-and-notifications)

Reference: [Workflow Streaming](https://docs.dbos.dev/typescript/tutorials/workflow-communication#workflow-streaming)

[Credential-related source omitted]

Reference: [DBOS Configuration](https://docs.dbos.dev/typescript/reference/configuration)

Reference: [Integrating DBOS](https://docs.dbos.dev/typescript/integrating-dbos)

// Can use this.cfg safely - instance is recoverable     const result = await DBOS.runStep(       () => fetch(this.cfg.apiUrl).then(r => r.text()),

const result = await DBOS.runStep(       () => fetch(this.cfg.apiUrl).then(r => r.text()),       { name: "callApi" }

() => fetch(this.cfg.apiUrl).then(r => r.text()),

// Create instances BEFORE DBOS.launch() const worker1 = new MyWorker("worker-us", { apiUrl: "https://us.api.com" });

const worker1 = new MyWorker("worker-us", { apiUrl: "https://us.api.com" });

const worker2 = new MyWorker("worker-eu", { apiUrl: "https://eu.api.com" });

Reference: [Using TypeScript Objects](https://docs.dbos.dev/typescript/tutorials/instantiated-objects)

Reference: [Debouncing Workflows](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#debouncing-workflows)

Reference: [Workflow IDs and Idempotency](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#workflow-ids-and-idempotency)

DBOS parses cron expressions with [node-cron](https://github.com/node-cron/node-cron#cron-syntax), so schedules support its full syntax, including an optional leading seconds field (`*/30 * * * * *` runs every 30 seconds).

Reference: [Scheduling Workflows](https://docs.dbos.dev/typescript/tutorials/scheduled-workflows)

Reference: [Durable Sleep](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#durable-sleep)

Reference: [DBOS Queues](https://docs.dbos.dev/typescript/tutorials/queue-tutorial)

Reference: [Managing Concurrency](https://docs.dbos.dev/typescript/tutorials/queue-tutorial#managing-concurrency)

Reference: [Deduplication](https://docs.dbos.dev/typescript/tutorials/queue-tutorial#deduplication)

Reference: [Delayed Execution](https://docs.dbos.dev/typescript/tutorials/queue-tutorial#delayed-execution)

Reference: [Explicit Queue Listening](https://docs.dbos.dev/typescript/tutorials/queue-tutorial#explicit-queue-listening)

Reference: [Queues Reference](https://docs.dbos.dev/typescript/reference/queues)

Reference: [Partitioning Queues](https://docs.dbos.dev/typescript/tutorials/queue-tutorial#partitioning-queues)

Reference: [Rate Limiting](https://docs.dbos.dev/typescript/tutorials/queue-tutorial#rate-limiting)

async function myWorkflowFn() {   // External API call directly in workflow - not checkpointed!   const response = await fetch("https://api.example.com/data");

// External API call directly in workflow - not checkpointed!   const response = await fetch("https://api.example.com/data");   return await response.json();

const response = await fetch("https://api.example.com/data");

async function fetchData() {   return await fetch("https://api.example.com/data").then(r => r.json());

return await fetch("https://api.example.com/data").then(r => r.json());

async function myWorkflowFn() {   const data = await DBOS.runStep(     () => fetch("https://api.example.com/data").then(r => r.json()),

const data = await DBOS.runStep(     () => fetch("https://api.example.com/data").then(r => r.json()),     { name: "fetchData" }

() => fetch("https://api.example.com/data").then(r => r.json()),

Reference: [DBOS Steps](https://docs.dbos.dev/typescript/tutorials/step-tutorial)

for (let attempt = 0; attempt < 3; attempt++) {     try {       return await fetch("https://api.example.com").then(r => r.json());

try {       return await fetch("https://api.example.com").then(r => r.json());     } catch (e) {

return await fetch("https://api.example.com").then(r => r.json());

async function fetchData() {   return await fetch("https://api.example.com").then(r => r.json());

return await fetch("https://api.example.com").then(r => r.json());

async function myWorkflowFn() {   const data = await DBOS.runStep(     () => fetch("https://api.example.com").then(r => r.json()),

const data = await DBOS.runStep(     () => fetch("https://api.example.com").then(r => r.json()),     { name: "fetchData", retriesAllowed: true, maxAttempts: 10 }

() => fetch("https://api.example.com").then(r => r.json()),

await DBOS.runStep(   async () => {     const r = await fetch(`https://api.example.com/users/${userId}`);

async () => {     const r = await fetch(`https://api.example.com/users/${userId}`);     if (!r.ok) throw new HTTPError(r.status);  // 404 retries 10 times before failing

const r = await fetch(`https://api.example.com/users/${userId}`);

await DBOS.runStep(   async () => {     const r = await fetch(`https://api.example.com/users/${userId}`);

async () => {     const r = await fetch(`https://api.example.com/users/${userId}`);     if (!r.ok) throw new HTTPError(r.status);

const r = await fetch(`https://api.example.com/users/${userId}`);

Reference: [Configurable Retries](https://docs.dbos.dev/typescript/tutorials/step-tutorial#configurable-retries)

async function fetchData() {   // No timeout: a hung server stalls this step   return await fetch("https://example.com").then((r) => r.text());

// No timeout: a hung server stalls this step   return await fetch("https://example.com").then((r) => r.text()); }

return await fetch("https://example.com").then((r) => r.text());

async function fetchData() {   // fetch aborts as soon as this attempt's timeout fires   const response = await fetch("https://example.com", { signal: DBOS.stepStatus?.timeoutSignal });

// fetch aborts as soon as this attempt's timeout fires   const response = await fetch("https://example.com", { signal: DBOS.stepStatus?.timeoutSignal });   return await response.text();

const response = await fetch("https://example.com", { signal: DBOS.stepStatus?.timeoutSignal });

const { timeoutSignal, cancelSignal } = DBOS.stepStatus!;   const signal = AbortSignal.any([timeoutSignal!, cancelSignal]);   const response = await fetch("https://example.com", { signal });

const signal = AbortSignal.any([timeoutSignal!, cancelSignal]);   const response = await fetch("https://example.com", { signal });   return await response.text();

const response = await fetch("https://example.com", { signal });

Reference: [Step Timeouts](https://docs.dbos.dev/typescript/tutorials/step-tutorial#step-timeouts)

Reference: [Transactions & Datasources](https://docs.dbos.dev/typescript/tutorials/transaction-tutorial)

Reference: [Testing & Mocking](https://docs.dbos.dev/typescript/tutorials/testing)

Reference: [Starting Workflows in Background](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#starting-workflows-in-the-background)

async function fetchData() {   // Steps only do external operations   return await fetch("https://api.example.com").then(r => r.json());

// Steps only do external operations   return await fetch("https://api.example.com").then(r => r.json()); }

return await fetch("https://api.example.com").then(r => r.json());

Reference: [Workflow Guarantees](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#workflow-guarantees)

Reference: [Workflow Management](https://docs.dbos.dev/typescript/tutorials/workflow-management)

Reference: [Workflow Determinism](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#determinism)

Reference: [Workflow Management](https://docs.dbos.dev/typescript/tutorials/workflow-management)

Reference: [Workflow Timeouts](https://docs.dbos.dev/typescript/tutorials/workflow-tutorial#workflow-timeouts)