Fixes queue for import task

This commit is contained in:
Mouse Reeve 2021-09-07 17:04:10 -07:00
parent de3f18655c
commit 26adf2d974

View file

@ -61,7 +61,7 @@ class Importer:
job.save()
@app.task(priority="low_priority")
@app.task(queue="low_priority")
def import_data(source, job_id):
"""does the actual lookup work in a celery task"""
job = ImportJob.objects.get(id=job_id)