mirror of
https://github.com/simon987/hexlib.git
synced 2025-04-10 06:06:41 +00:00
Make sure that _id field is present in redis MQ
This commit is contained in:
parent
428c82bcfd
commit
62e74ed292
@ -120,7 +120,7 @@ class RedisMQ(MessageQueue):
|
|||||||
task_json = orjson.loads(task)
|
task_json = orjson.loads(task)
|
||||||
topic = topic.decode()
|
topic = topic.decode()
|
||||||
|
|
||||||
if "_id" not in task_json:
|
if "_id" not in task_json or not task_json["_id"]:
|
||||||
raise ValueError(f"Task doesn't have _id field: {task}")
|
raise ValueError(f"Task doesn't have _id field: {task}")
|
||||||
|
|
||||||
# Immediately put in pending queue
|
# Immediately put in pending queue
|
||||||
|
2
setup.py
2
setup.py
@ -2,7 +2,7 @@ from setuptools import setup
|
|||||||
|
|
||||||
setup(
|
setup(
|
||||||
name="hexlib",
|
name="hexlib",
|
||||||
version="1.71",
|
version="1.72",
|
||||||
description="Misc utility methods",
|
description="Misc utility methods",
|
||||||
author="simon987",
|
author="simon987",
|
||||||
author_email="me@simon987.net",
|
author_email="me@simon987.net",
|
||||||
|
Loading…
x
Reference in New Issue
Block a user