cancelWorkflowExecution method

@override Future<bool> cancelWorkflowExecution(String executionId)

Cancel workflow execution

Implementation

@override
Future<bool> cancelWorkflowExecution(String executionId) async {
  final execution = _executionResults[executionId];
  if (execution == null) return false;

  if (execution.status == WorkflowStatus.running) {
    final cancelledExecution = WorkflowExecutionResult(
      workflowId: execution.workflowId,
      executionId: executionId,
      status: WorkflowStatus.cancelled,
      result: execution.result,
      error: null,
      startedAt: execution.startedAt,
      completedAt: DateTime.now(),
    );

    _executionResults[executionId] = cancelledExecution;

    _eventController.add(WorkflowEvent(
      executionId: executionId,
      eventType: WorkflowEventType.workflowCancelled,
      stepId: null,
      data: null,
      error: null,
      timestamp: DateTime.now(),
    ));

    return true;
  }

  return false;
}