def run_job(tasks):
 log.debug(u'executing tasks: %s', tasks)
 finished_events = manager.execute(options={u'tasks': tasks, u'cron': True, u'allow_manual': False}, priority=5)
 for (_, task_name, event_) in finished_events:
  log.debug(u'task finished executing: %s', task_name)
  event_.wait()
 log.debug(u'all tasks in schedule finished executing')

def run_job ( tasks ) : log . debug ( u'executing tasks: %s' , tasks ) finished_events = manager . execute ( options = { u'tasks' : tasks , u'cron' : True , u'allow_manual' : False } , priority = 5 ) for ( _ , task_name , event_ ) in finished_events : log . debug ( u'task finished executing: %s' , task_name ) event_ . wait ( ) log . debug ( u'all tasks in schedule finished executing' )
run a scheduled job on the minion immediately cli example: .