anchor.diff:        }
   
         await runTask(task);
  +
  +      // Throttle processing in case there was a network issue.
  +      if (errorCount >= 5) {
  +        _logger.warning(
  +            'Sleeping 1 minute after 5 errors, before trying more tasks.');
  +        await Future.delayed(Duration(minutes: 1));
  +        errorCount = 0;
  +      }
       }
     }
   
  
positive.code:   }
  
    Future run() async {
      Future runTask(Task task) async {
        final Stopwatch sw = Stopwatch()..start();
        try {
  
negative.code:         await taskRunner.runTask(task);
          _statusTracker.add('normal');
        } catch (e, st) {
          errorCount++;
          _logger.severe('Error processing task: $task', e, st);
          _statusTracker.add('error');
        }
  