##// END OF EJS Templates
chore(deps): bumped celery to 5.3.6 and kombu to latest version
super-admin -
r1205:b35336c8 default
parent child Browse files
Show More
@@ -2,8 +2,8 b''
2
2
3 async-timeout==4.0.3
3 async-timeout==4.0.3
4 atomicwrites==1.4.1
4 atomicwrites==1.4.1
5 celery==5.3.4
5 celery==5.3.6
6 billiard==4.1.0
6 billiard==4.2.0
7 click==8.1.3
7 click==8.1.3
8 click-didyoumean==0.3.0
8 click-didyoumean==0.3.0
9 click==8.1.3
9 click==8.1.3
@@ -14,8 +14,8 b' celery==5.3.4'
14 prompt-toolkit==3.0.38
14 prompt-toolkit==3.0.38
15 wcwidth==0.2.6
15 wcwidth==0.2.6
16 six==1.16.0
16 six==1.16.0
17 kombu==5.3.2
17 kombu==5.3.5
18 amqp==5.1.1
18 amqp==5.2.0
19 vine==5.1.0
19 vine==5.1.0
20 vine==5.1.0
20 vine==5.1.0
21 python-dateutil==2.8.2
21 python-dateutil==2.8.2
@@ -20,7 +20,6 b' import os'
20 import sys
20 import sys
21 import logging
21 import logging
22 import collections
22 import collections
23 import importlib
24 import base64
23 import base64
25 import msgpack
24 import msgpack
26 import dataclasses
25 import dataclasses
@@ -29,7 +28,6 b' import pygit2'
29 import http.client
28 import http.client
30 from celery import Celery
29 from celery import Celery
31
30
32
33 import mercurial.scmutil
31 import mercurial.scmutil
34 import mercurial.node
32 import mercurial.node
35
33
@@ -38,7 +36,7 b' from vcsserver import exceptions, subpro'
38 from vcsserver.str_utils import ascii_str, safe_str
36 from vcsserver.str_utils import ascii_str, safe_str
39 from vcsserver.remote.git_remote import Repository
37 from vcsserver.remote.git_remote import Repository
40
38
41 celery_app = Celery()
39 celery_app = Celery('__vcsserver__')
42 log = logging.getLogger(__name__)
40 log = logging.getLogger(__name__)
43
41
44
42
@@ -94,7 +92,8 b' class HooksCeleryClient:'
94 TASK_TIMEOUT = 60 # time in seconds
92 TASK_TIMEOUT = 60 # time in seconds
95
93
96 def __init__(self, queue, backend):
94 def __init__(self, queue, backend):
97 celery_app.config_from_object({'broker_url': queue, 'result_backend': backend,
95 celery_app.config_from_object({
96 'broker_url': queue, 'result_backend': backend,
98 'broker_connection_retry_on_startup': True,
97 'broker_connection_retry_on_startup': True,
99 'task_serializer': 'msgpack',
98 'task_serializer': 'msgpack',
100 'accept_content': ['json', 'msgpack'],
99 'accept_content': ['json', 'msgpack'],
General Comments 0
You need to be logged in to leave comments. Login now