Type Alias TaskRunContext

Example

const task = executor.task({
  id: 'processData',
  timeoutMs: 60000,
  run: async (ctx, input) => {
    console.log(`Execution ${ctx.executionId}, attempt ${ctx.attempt}`)

    // Check for executor shutdown or task cancellation
    if (ctx.shutdownSignal.aborted || ctx.abortSignal.aborted) {
      throw new DurableExecutionCancelledError()
    }

    // Check previous error if retrying
    if (ctx.prevError) {
      console.log('Retrying after:', ctx.prevError.message)
    }

    // Process data...
    return result
  }
})
Copy