Show More
@@ -2,8 +2,8 b'' | |||
|
2 | 2 | |
|
3 | 3 | async-timeout==4.0.3 |
|
4 | 4 | atomicwrites==1.4.1 |
|
5 |
celery==5.3. |
|
|
6 |
billiard==4. |
|
|
5 | celery==5.3.6 | |
|
6 | billiard==4.2.0 | |
|
7 | 7 | click==8.1.3 |
|
8 | 8 | click-didyoumean==0.3.0 |
|
9 | 9 | click==8.1.3 |
@@ -14,8 +14,8 b' celery==5.3.4' | |||
|
14 | 14 | prompt-toolkit==3.0.38 |
|
15 | 15 | wcwidth==0.2.6 |
|
16 | 16 | six==1.16.0 |
|
17 |
kombu==5.3. |
|
|
18 |
amqp==5. |
|
|
17 | kombu==5.3.5 | |
|
18 | amqp==5.2.0 | |
|
19 | 19 | vine==5.1.0 |
|
20 | 20 | vine==5.1.0 |
|
21 | 21 | python-dateutil==2.8.2 |
@@ -20,7 +20,6 b' import os' | |||
|
20 | 20 | import sys |
|
21 | 21 | import logging |
|
22 | 22 | import collections |
|
23 | import importlib | |
|
24 | 23 | import base64 |
|
25 | 24 | import msgpack |
|
26 | 25 | import dataclasses |
@@ -29,7 +28,6 b' import pygit2' | |||
|
29 | 28 | import http.client |
|
30 | 29 | from celery import Celery |
|
31 | 30 | |
|
32 | ||
|
33 | 31 | import mercurial.scmutil |
|
34 | 32 | import mercurial.node |
|
35 | 33 | |
@@ -38,7 +36,7 b' from vcsserver import exceptions, subpro' | |||
|
38 | 36 | from vcsserver.str_utils import ascii_str, safe_str |
|
39 | 37 | from vcsserver.remote.git_remote import Repository |
|
40 | 38 | |
|
41 | celery_app = Celery() | |
|
39 | celery_app = Celery('__vcsserver__') | |
|
42 | 40 | log = logging.getLogger(__name__) |
|
43 | 41 | |
|
44 | 42 | |
@@ -94,7 +92,8 b' class HooksCeleryClient:' | |||
|
94 | 92 | TASK_TIMEOUT = 60 # time in seconds |
|
95 | 93 | |
|
96 | 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 |
|
|
99 | 98 |
|
|
100 | 99 |
|
General Comments 0
You need to be logged in to leave comments.
Login now