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. |
|
5 | celery==5.3.6 | |
6 |
billiard==4. |
|
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. |
|
17 | kombu==5.3.5 | |
18 |
amqp==5. |
|
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({ |
|
95 | celery_app.config_from_object({ | |
|
96 | 'broker_url': queue, 'result_backend': backend, | |||
98 |
|
|
97 | 'broker_connection_retry_on_startup': True, | |
99 |
|
|
98 | 'task_serializer': 'msgpack', | |
100 |
|
|
99 | 'accept_content': ['json', 'msgpack'], |
General Comments 0
You need to be logged in to leave comments.
Login now