darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-08-24 00:06:16 -04:00
Code Issues Packages Projects Releases Wiki Activity

Made celery task arg a tuple

Browse Source
This commit is contained in:
Ken Tsang
2017-08-23 18:05:48 +01:00
parent 7aaef8fc09
commit 451c5a9f1a
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/celery/scheduled_tasks.py
View File

@@ -311,7 +311,7 @@ def run_letter_jobs():
job_ids = [job.id for job in dao_get_letter_jobs_by_status(JOB_STATUS_READY_TO_SEND)] job_ids = [job.id for job in dao_get_letter_jobs_by_status(JOB_STATUS_READY_TO_SEND)]
notify_celery.send_task( notify_celery.send_task(
name=TaskNames.DVLA_FILES, name=TaskNames.DVLA_FILES,
args=(job_ids), args=(job_ids,),
queue=QueueNames.PROCESS_FTP queue=QueueNames.PROCESS_FTP
) )
current_app.logger.info("Queued {} ready letter job ids onto {}".format(len(job_ids), QueueNames.PROCESS_FTP)) current_app.logger.info("Queued {} ready letter job ids onto {}".format(len(job_ids), QueueNames.PROCESS_FTP))

2
tests/app/celery/test_scheduled_tasks.py
View File

@@ -696,5 +696,5 @@ def test_run_letter_jobs(client, mocker, sample_letter_template):
run_letter_jobs() run_letter_jobs()
mock_celery.assert_called_once_with(name=TaskNames.DVLA_FILES, mock_celery.assert_called_once_with(name=TaskNames.DVLA_FILES,
args=([job.id for job in jobs]), args=([job.id for job in jobs],),
queue=QueueNames.PROCESS_FTP) queue=QueueNames.PROCESS_FTP)