We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9f4fcbd commit ab164d0Copy full SHA for ab164d0
cads_broker/dispatcher.py
@@ -311,7 +311,7 @@ def set_request_error_status(
311
session=session,
312
)
313
requeue = False
314
- if requeue and request.request_metadata.get("resubmit", 0) < os.getenv(
+ if requeue and request.request_metadata.get("resubmit_number", 0) < os.getenv(
315
"BROKER_REQUEUE_LIMIT", 3
316
):
317
logger.info("worker killed: re-queueing", job_id=request_uid)
@@ -441,7 +441,7 @@ def sync_database(self, session: sa.orm.Session) -> None:
441
# FIXME: check if request status has changed
442
if os.getenv(
443
"BROKER_REQUEUE_ON_LOST_REQUESTS", True
444
- ) and request.request_metadata.get("resubmit", 0) < os.getenv(
+ ) and request.request_metadata.get("resubmit_number", 0) < os.getenv(
445
446
447
logger.info(
0 commit comments