diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py index 5cc35f257..16fcf0d4f 100644 --- a/app/celery/scheduled_tasks.py +++ b/app/celery/scheduled_tasks.py @@ -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)] notify_celery.send_task( name=TaskNames.DVLA_FILES, - args=(job_ids), + args=(job_ids,), queue=QueueNames.PROCESS_FTP ) current_app.logger.info("Queued {} ready letter job ids onto {}".format(len(job_ids), QueueNames.PROCESS_FTP)) diff --git a/tests/app/celery/test_scheduled_tasks.py b/tests/app/celery/test_scheduled_tasks.py index 78d46a54b..cc638c01b 100644 --- a/tests/app/celery/test_scheduled_tasks.py +++ b/tests/app/celery/test_scheduled_tasks.py @@ -696,5 +696,5 @@ def test_run_letter_jobs(client, mocker, sample_letter_template): run_letter_jobs() 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)