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.
2 parents b465e63 + 2ab4f3a commit d0fcb39Copy full SHA for d0fcb39
src/agentlab/experiments/graph_execution_ray.py
@@ -2,12 +2,14 @@
2
3
# # Disable Ray log deduplication
4
# os.environ["RAY_DEDUP_LOGS"] = "0"
5
+import logging
6
import time
-import ray
7
+
8
import bgym
-from agentlab.experiments.exp_utils import run_exp, _episode_timeout
9
+import ray
10
from ray.util import state
-import logging
11
12
+from agentlab.experiments.exp_utils import _episode_timeout, run_exp
13
14
logger = logging.getLogger(__name__)
15
@@ -36,6 +38,7 @@ def get_task(exp_arg: bgym.ExpArgs):
36
38
get_task(exp_arg)
37
39
40
max_timeout = max([_episode_timeout(exp_args, avg_step_timeout) for exp_args in exp_args_list])
41
42
return poll_for_timeout(task_map, max_timeout, poll_interval=max_timeout * 0.1)
43
44
0 commit comments