2025-summer/team-3
12
Fork 0
Code Issues Pull requests Projects Releases Activity

raise task errors if CELERY_ALWAYS_EAGER=True

Browse source
This commit is contained in:
Laura Klünder 2016-10-05 19:04:51 +02:00
parent 6753907df5
commit 5a268109e4
1 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/c3nav/editor/hosters/base.py
View file

@ -55,6 +55,8 @@ class Hoster(ABC):
if state == 'checking': if state == 'checking':
task = AsyncResult(id=session_data.get('checking_progress_id')) 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) self._handle_checking_task(request, task, session_data)
state = session_data['state'] state = session_data['state']
@ -73,6 +75,8 @@ class Hoster(ABC):
if state == 'logged_in': if state == 'logged_in':
session_data['state'] = 'checking' session_data['state'] = 'checking'
task = check_access_token_task.delay(hoster=self.name, access_token=session_data['access_token']) 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 session_data['checking_progress_id'] = task.id
self._handle_checking_task(request, task, session_data) self._handle_checking_task(request, task, session_data)
@ -103,6 +107,8 @@ class Hoster(ABC):
def submit_edit(self, request, data): def submit_edit(self, request, data):
session_data = self._get_session_data(request) session_data = self._get_session_data(request)
task = submit_edit_task.delay(access_token=session_data['access_token'], data=data) task = submit_edit_task.delay(access_token=session_data['access_token'], data=data)
if settings.CELERY_ALWAYS_EAGER:
task.maybe_reraise()
return task return task
@abstractmethod @abstractmethod