Skip to content

Commit c407ab4

Browse files
improve logs
1 parent 6ac6850 commit c407ab4

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

api/scpca_portal/management/commands/pause_processing.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,13 @@ def handle(self, *args, **kwargs):
1717
self.pause_processing()
1818

1919
def pause_processing(self):
20-
terminated_jobs = Job.terminate_processing(reason="Processing paused on re-deploy.")
20+
termination_reason = "Processing paused via pause_processing command."
21+
terminated_jobs = Job.terminate_processing(reason=termination_reason)
22+
2123
retry_jobs = Job.create_retry_jobs(terminated_jobs)
2224

2325
retry_job_count = len(retry_jobs)
2426
logger.info(
2527
f"{retry_job_count} processing job{pluralize(retry_job_count)} were paused "
26-
"and added to the pending queue before deploy."
28+
"and added to the pending queue."
2729
)

0 commit comments

Comments
 (0)