GetTaskInstance

Source: src/AWS/MWAAServerless/GetTaskInstance.ts

Runtime binding for airflow-serverless:GetTaskInstance.

Reads the detail of a single task instance within a run of the bound Workflow — its status, attempt number, timings, error message, log stream, and XCom values. Provide the implementation with Effect.provide(AWS.MWAAServerless.GetTaskInstanceHttp).

Observing Tasks

// init — bind the operation to the workflow
const getTaskInstance = yield* AWS.MWAAServerless.GetTaskInstance(workflow);

// runtime
const task = yield* getTaskInstance({
  RunId: runId,
  TaskInstanceId: taskInstanceId,
});
yield* Effect.log(`task ${task.TaskId}: ${task.Status}`);