From 65d01d508b7a45ab5eae4cf0934861c50c24f12c Mon Sep 17 00:00:00 2001 From: Matthew Jones Date: Wed, 15 Nov 2017 13:12:06 -0500 Subject: [PATCH] Fix an issue with handler tasks after celery upgrade There's a bug in celery 4.X when using bound tasks as error handlers. We don't actually need it to be bound especially since the request object is now available in the function signature --- awx/main/tasks.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/awx/main/tasks.py b/awx/main/tasks.py index a0963c73ce..4e62f52298 100644 --- a/awx/main/tasks.py +++ b/awx/main/tasks.py @@ -357,9 +357,9 @@ def handle_work_success(self, result, task_actual): run_job_complete.delay(instance.id) -@shared_task(bind=True, queue='tower', base=LogErrorsTask) -def handle_work_error(self, task_id, subtasks=None): - logger.debug('Executing error task id %s, subtasks: %s' % (str(self.request.id), str(subtasks))) +@shared_task(queue='tower', base=LogErrorsTask) +def handle_work_error(request, exc, traceback, task_id, subtasks=None): + logger.debug('Executing error task id %s, subtasks: %s' % (request.id, str(subtasks))) first_instance = None first_instance_type = '' if subtasks is not None: