We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 53e62b6 + 16f3d1e commit 466a96bCopy full SHA for 466a96b
cads_broker/dispatcher.py
@@ -574,7 +574,7 @@ def submit_requests(
574
candidates: Iterable[db.SystemRequest],
575
) -> None:
576
"""Check the qos rules and submit the requests to the dask scheduler."""
577
- if "BROKER_PRIORITY_ALGORITHM" == "processing_time":
+ if BROKER_PRIORITY_ALGORITHM == "processing_time":
578
user_requests: dict[str, list[db.SystemRequest]] = {}
579
for request in candidates:
580
user_requests.setdefault(request.user_uid, []).append(request)
0 commit comments