From 5a268109e4b8e0f52da20300dd63e5153381df96 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Laura=20Kl=C3=BCnder?= Date: Wed, 5 Oct 2016 19:04:51 +0200 Subject: [PATCH] raise task errors if CELERY_ALWAYS_EAGER=True --- src/c3nav/editor/hosters/base.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/c3nav/editor/hosters/base.py b/src/c3nav/editor/hosters/base.py index 8357a0aa..9bfc35fc 100644 --- a/src/c3nav/editor/hosters/base.py +++ b/src/c3nav/editor/hosters/base.py @@ -55,6 +55,8 @@ class Hoster(ABC): if state == 'checking': task = AsyncResult(id=session_data.get('checking_progress_id')) + if settings.CELERY_ALWAYS_EAGER: + task.maybe_reraise() self._handle_checking_task(request, task, session_data) state = session_data['state'] @@ -73,6 +75,8 @@ class Hoster(ABC): if state == 'logged_in': session_data['state'] = 'checking' task = check_access_token_task.delay(hoster=self.name, access_token=session_data['access_token']) + if settings.CELERY_ALWAYS_EAGER: + task.maybe_reraise() session_data['checking_progress_id'] = task.id self._handle_checking_task(request, task, session_data) @@ -103,6 +107,8 @@ class Hoster(ABC): def submit_edit(self, request, data): session_data = self._get_session_data(request) task = submit_edit_task.delay(access_token=session_data['access_token'], data=data) + if settings.CELERY_ALWAYS_EAGER: + task.maybe_reraise() return task @abstractmethod