@@ -415,6 +415,11 @@ def run(self):
415415 try :
416416 logger .info (f"Running experiment { self .exp_name } in:\n { self .exp_dir } " )
417417 agent = self .agent_args .make_agent ()
418+
419+ # Set training data directory for agents that support it
420+ if hasattr (agent , 'set_training_data_dir' ):
421+ agent .set_training_data_dir (Path (self .exp_dir ))
422+
418423 if hasattr (agent , "set_task_name" ):
419424 agent .set_task_name (self .env_args .task_name )
420425
@@ -436,6 +441,11 @@ def run(self):
436441
437442 while not step_info .is_done : # set a limit
438443 logger .debug (f"Starting step { step_info .step } ." )
444+
445+ # Set current step for training data capture
446+ if hasattr (agent , 'set_current_step' ):
447+ agent .set_current_step (step_info .step )
448+
439449 action = step_info .from_action (agent )
440450 logger .debug (f"Agent chose action:\n { action } " )
441451
@@ -926,6 +936,8 @@ def _get_env_name(task_name: str):
926936 import browsergym .assistantbench
927937 elif task_name .startswith ("weblinx" ):
928938 import weblinx_browsergym
939+ elif task_name .startswith ("timewarp" ):
940+ import browsergym .timewarp
929941
930942 return f"browsergym/{ task_name } "
931943
0 commit comments