We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c01defe commit 435b390Copy full SHA for 435b390
joshua/joshua_agent.py
@@ -748,14 +748,9 @@ def agent(
748
ensembles_can_run = list(
749
filter(joshua_model.should_run_ensemble, ensembles)
750
)
751
- if not ensembles_can_run:
752
- # All the ensembles have enough runs started for now. Don't
753
- # time the agent out, just wait until there are no
754
- # ensembles or the other agents might have died.
755
- time.sleep(1)
756
- continue
757
- else:
758
- # No ensembles at all. Consider timing this agent out.
+
+ if not ensembles or (ensembles and not ensembles_can_run):
+ # No ensembles to run. Consider timing this agent out.
759
try:
760
watch.wait_for_any(watch, sanity_watch, TimeoutFuture(1.0))
761
except Exception as e:
0 commit comments