monitorExecution static method

Stream<TaskStatus> monitorExecution(
  1. String executionId
)

Monitors the status of a specific task execution.

Implementation

static Stream<TaskStatus> monitorExecution(String executionId) {
  return TaskFlowPlatform.instance.taskEvents
      .where((event) => event['executionId'] == executionId)
      .map((event) => TaskStatus.fromMap(event));
}