gavindiaz/NexQuant
1
0
Fork 0
mirror of https://github.com/NicolasBohn/NexQuant.git synced 2026-07-27 23:47:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: prevent parallelism in feedback and record steps (#1046)

Browse Source
This commit is contained in:
you-n-g
2025-07-09 18:36:05 +08:00
committed by GitHub
parent c03a519cbc
commit 12d4e8a850
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rdagent/utils/workflow/loop.py
+6 -3
View File
@@ -136,9 +136,12 @@ class LoopBase:
if isinstance(limit := RD_AGENT_SETTINGS.step_semaphore, dict):
limit = limit.get(step_name, 1) # default to 1 if not specified
# NOTE: we assume the record step is always the last step to modify the global environment,
# so we set the limit to 1 to avoid race condition
if step_name == "record":
# NOTE:
# (1) we assume the record step is always the last step to modify the global environment,
# so we set the limit to 1 to avoid race condition
# (2) Because we support (-1,) as local selection; So it is hard to align a) the comparision target in `feedbck`
# and b) parent node in `record`; So we prevent parallelism in `feedback` and `record` to avoid inconsistency
if step_name in ("record", "feedback"):
limit = 1
if step_name not in self.semaphores: