docs: def terminate_all(self):
          """ Terminate all currently running tasks. """
          logger.info('Job {0} terminating all currently running tasks'.format(self.name))
          for task in self.tasks.itervalues():
              if task.started_at and not task.completed_at:
                  task.terminate()