Celery JSON serializable object for override_tag_ids

This commit is contained in:
Michael Shamoon 2022-11-06 22:02:01 -08:00 committed by Trenton H
parent 39149a891c
commit 91a2dedfec

View File

@ -94,7 +94,7 @@ def _consume(filepath):
logger.info(f"Adding {filepath} to the task queue.") logger.info(f"Adding {filepath} to the task queue.")
consume_file.delay( consume_file.delay(
filepath, filepath,
override_tag_ids=tag_ids if tag_ids else None, override_tag_ids=list(tag_ids) if tag_ids else None,
) )
except Exception: except Exception:
# Catch all so that the consumer won't crash. # Catch all so that the consumer won't crash.