markSucceeded method

void markSucceeded(
  1. ExecutionDAG dag,
  2. String taskId,
  3. TaskResult result
)

Marks taskId as succeeded with result.

Implementation

void markSucceeded(ExecutionDAG dag, String taskId, TaskResult result) {
  final task = dag[taskId];
  if (task == null) return;
  task.status = TaskStatus.succeeded;
  task.result = result;
  task.finishedAt = DateTime.now();
  _logger.info('Task succeeded: "${_trunc(task.description)}" '
      '(${task.duration?.inMilliseconds ?? 0}ms)');
}