arthur/scheduler.py
def _handle_failed_job(self, job):
        """Handle failed jobs"""

        task_id = job.kwargs['task_id']
        logger.error("Job #%s (task: %s) failed; cancelled",
                     job.id, task_id)
def _handle_failed_job(self, job):
        task_id = job.kwargs['task_id']
        logger.error("Job #%s (task: %s) failed; cancelled",
                     job.id, task_id)
def _handle_failed_job ( self , job ) : task_id = job . kwargs [ 'task_id' ] logger . error ( "Job #%s (task: %s) failed; cancelled" , job . id , task_id )
Handle failed jobs
Handle failed jobs