chore(deps): bumped celery to 5.3.6 and kombu to latest version

requirements.txt

@@ -2,8 +2,8 b''
 
 async-timeout==4.0.3
 atomicwrites==1.4.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
@@ -14,8 +14,8 b' 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

vcsserver/hooks.py

@@ -20,7 +20,6 b' import os'
 import sys
 import logging
 import collections
-import importlib
 import base64
 import msgpack
 import dataclasses
@@ -29,7 +28,6 b' import pygit2'
 import http.client
 from celery import Celery
 
-
 import mercurial.scmutil
 import mercurial.node
 
@@ -38,7 +36,7 b' from vcsserver import exceptions, subpro'
 from vcsserver.str_utils import ascii_str, safe_str
 from vcsserver.remote.git_remote import Repository
 
-celery_app = Celery()
+celery_app = Celery('__vcsserver__')
 log = logging.getLogger(__name__)
 
 
@@ -94,13 +92,14 b' class HooksCeleryClient:'
     TASK_TIMEOUT = 60  # time in seconds
 
     def __init__(self, queue, backend):
-        celery_app.config_from_object({'broker_url': queue, 'result_backend': backend,
-                                       'broker_connection_retry_on_startup': True,
-                                        'task_serializer': 'msgpack',
-                                        'accept_content': ['json', 'msgpack'],
-                                        'result_serializer': 'msgpack',
-                                        'result_accept_content': ['json', 'msgpack']
-                                       })
+        celery_app.config_from_object({
+            'broker_url': queue, 'result_backend': backend,
+            'broker_connection_retry_on_startup': True,
+            'task_serializer': 'msgpack',
+            'accept_content': ['json', 'msgpack'],
+            'result_serializer': 'msgpack',
+            'result_accept_content': ['json', 'msgpack']
+        })
         self.celery_app = celery_app
 
     def __call__(self, method, extras):