diff --git a/requirements.txt b/requirements.txt --- a/requirements.txt +++ b/requirements.txt @@ -9,8 +9,8 @@ alembic==1.12.1 async-timeout==4.0.3 babel==2.12.1 beaker==1.12.1 -celery==5.3.4 - billiard==4.1.0 +celery==5.3.6 + billiard==4.2.0 click==8.1.3 click-didyoumean==0.3.0 click==8.1.3 @@ -21,8 +21,8 @@ celery==5.3.4 prompt-toolkit==3.0.38 wcwidth==0.2.6 six==1.16.0 - kombu==5.3.2 - amqp==5.1.1 + kombu==5.3.5 + amqp==5.2.0 vine==5.1.0 vine==5.1.0 python-dateutil==2.8.2 diff --git a/rhodecode/lib/celerylib/__init__.py b/rhodecode/lib/celerylib/__init__.py --- a/rhodecode/lib/celerylib/__init__.py +++ b/rhodecode/lib/celerylib/__init__.py @@ -46,7 +46,6 @@ def run_task(task, *args, **kwargs): if task is None: raise ValueError(f'Got non-existing task: {task} for execution') - exec_mode = 'sync' allow_async = True # if we're already in a celery task, don't allow async execution again