docs: def kill_all(self):
          """ Kill all currently running jobs. """
          logger.info('Job {0} killing all currently running tasks'.format(self.name))
          for task in self.tasks.itervalues():
              if task.started_at and not task.completed_at:
                  task.kill()