Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 8 additions & 7 deletions src/agentlab/experiments/exp_utils.py
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
import os
from pathlib import Path
from browsergym.experiments.loop import _move_old_exp, yield_all_exp_results
from tqdm import tqdm
import logging
from browsergym.experiments.loop import ExpArgs
from contextlib import contextmanager
import os
import signal
import sys
from time import time, sleep
from contextlib import contextmanager
from pathlib import Path
from time import sleep, time

from browsergym.experiments.loop import ExpArgs, _move_old_exp, yield_all_exp_results
from tqdm import tqdm

logger = logging.getLogger(__name__) # Get logger based on module name

Expand Down Expand Up @@ -130,6 +130,7 @@ def add_dependencies(exp_args_list: list[ExpArgs], task_dependencies: dict[str,
class MockedExpArgs:
def __init__(self, exp_id, depends_on=None):
self.exp_id = exp_id
self.exp_name = f"exp_{exp_id}"
self.depends_on = depends_on if depends_on else []
self.start_time = None
self.end_time = None
Expand Down
2 changes: 1 addition & 1 deletion src/agentlab/experiments/graph_execution_ray.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ def get_task(exp_arg: bgym.ExpArgs):
dependency_tasks = [get_task(exp_args_map[dep_key]) for dep_key in exp_arg.depends_on]

# Create new task that depends on the dependency results
task_map[exp_arg.exp_id] = run_exp.remote(
task_map[exp_arg.exp_id] = run_exp.options(name=f"{exp_arg.exp_name}").remote(
exp_arg, *dependency_tasks, avg_step_timeout=avg_step_timeout
)
return task_map[exp_arg.exp_id]
Expand Down