File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -61,7 +61,9 @@ def _shutdown(signalnum, _):
61
61
62
62
@cli .command ()
63
63
def clear_completed ():
64
- cutoff = timezone .now () - datetime .timedelta (seconds = settings .WORKER_JOBS_CLEARABLE_AFTER )
64
+ cutoff = timezone .now () - datetime .timedelta (
65
+ seconds = settings .WORKER_JOBS_CLEARABLE_AFTER
66
+ )
65
67
click .echo (f"Clearing jobs finished before { cutoff } " )
66
68
results = (
67
69
JobResult .objects .exclude (ended_at__isnull = True )
Original file line number Diff line number Diff line change @@ -167,7 +167,8 @@ def process_job(job_uuid):
167
167
job .source ,
168
168
)
169
169
170
- middleware_chain = lambda job : job .run ()
170
+ def middleware_chain (job ):
171
+ return job .run ()
171
172
172
173
for middleware_path in reversed (settings .WORKER_MIDDLEWARE ):
173
174
middleware_class = import_string (middleware_path )
You can’t perform that action at this time.
0 commit comments