arthur/scheduler.py
def cancel_job_task(self, task_id):
        """Cancel the job related to the given task."""

        try:
            self._rwlock.writer_acquire()

            job_id = self._tasks.get(task_id, None)

            if job_id:
                self._cancel_job(job_id)
            else:
                logger.warning("Task %s set to be removed was not found",
                               task_id)
        finally:
            self._rwlock.writer_release()
def cancel_job_task(self, task_id):
        try:
            self._rwlock.writer_acquire()

            job_id = self._tasks.get(task_id, None)

            if job_id:
                self._cancel_job(job_id)
            else:
                logger.warning("Task %s set to be removed was not found",
                               task_id)
        finally:
            self._rwlock.writer_release()
def cancel_job_task ( self , task_id ) : try : self . _rwlock . writer_acquire ( ) job_id = self . _tasks . get ( task_id , None ) if job_id : self . _cancel_job ( job_id ) else : logger . warning ( "Task %s set to be removed was not found" , task_id ) finally : self . _rwlock . writer_release ( )
Cancel the job related to the given task.
Cancel the job related to the given task .