File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change 14
14
15
15
import logging
16
16
17
- import django_rq
18
17
from ansible_base .lib .utils .db import advisory_lock
19
18
20
19
from aap_eda .analytics import collector , utils
29
28
ANALYTICS_JOB_ID = "job_gather_analytics"
30
29
ANALYTICS_TASKS_QUEUE = "default"
31
30
32
- # Wrap the django_rq job decorator so its processing is within our retry
33
- # code.
34
- job = tasking .redis_connect_retry ()(django_rq .job )
35
-
36
31
37
32
def schedule_gather_analytics (
38
33
queue_name : str = ANALYTICS_TASKS_QUEUE , cancel : bool = False
@@ -74,7 +69,6 @@ def reschedule_gather_analytics(
74
69
return reschedule_gather_analytics_rq (queue_name )
75
70
76
71
77
- @job (ANALYTICS_TASKS_QUEUE )
78
72
def reschedule_gather_analytics_rq (
79
73
queue_name : str = ANALYTICS_TASKS_QUEUE ,
80
74
) -> None :
You can’t perform that action at this time.
0 commit comments