markRunning method

void markRunning(
  1. ExecutionDAG dag,
  2. String taskId
)

Marks taskId as running.

Implementation

void markRunning(ExecutionDAG dag, String taskId) {
  final task = dag[taskId];
  if (task == null) return;
  task.status = TaskStatus.running;
  task.startedAt = DateTime.now();
  _logger.debug('Task running: "$taskId"');
}