markRunning method

@override Future<void> markRunning(String runId, { String? stepName, })

Marks a run as actively executing at stepName.

Implementation

@override
/// Marks a run as actively executing at [stepName].
Future<void> markRunning(String runId, {String? stepName}) async {
  final state = _runs[runId];
  if (state == null) return;
  _removeWatcherForRun(runId);
  _runs[runId] = state.copyWith(
    status: WorkflowStatus.running,
    updatedAt: _clock.now(),
  );
}