anchor.diff:          await taskRunner.runTask(task);
           _statusTracker.add('normal');
         } catch (e, st) {
  +        errorCount++;
           _logger.severe('Error processing task: $task', e, st);
           _statusTracker.add('error');
         }
  
positive.code:       }
  
        await runTask(task);
      }
    }
  
  
negative.code:   }
  
    Future run() async {
      int errorCount = 0;
  
      Future runTask(Task task) async {
        final Stopwatch sw = Stopwatch()..start();
        try {
  