|
25 | 25 | from PIL import Image |
26 | 26 | from tqdm import tqdm |
27 | 27 |
|
28 | | -# from agentlab.agents.tapeagent import TapeAgent, save_tape |
| 28 | +from agentlab.agents.tapeagent import TapeAgent, save_tape |
29 | 29 |
|
30 | 30 | logger = logging.getLogger(__name__) |
31 | 31 |
|
@@ -236,10 +236,6 @@ def make_stats(self): |
236 | 236 | stats = {} |
237 | 237 | stats.update(self.agent_info.pop("stats", {})) |
238 | 238 |
|
239 | | - # messages = self.agent_info.get("chat_messages", None) |
240 | | - # if messages is not None: |
241 | | - # stats["n_token_agent_messages"] = count_messages_token(messages) |
242 | | - |
243 | 239 | t = self.profiling |
244 | 240 | stats["step_elapsed"] = t.env_stop - t.env_start |
245 | 241 | stats["agent_elapsed"] = t.agent_stop - t.agent_start |
@@ -477,9 +473,9 @@ def run(self): |
477 | 473 | err_msg = f"Exception uncaught by agent or environment in task {self.env_args.task_name}.\n{type(e).__name__}:\n{e}" |
478 | 474 | logger.info("Saving experiment info.") |
479 | 475 | self.save_summary_info(episode_info, Path(self.exp_dir), err_msg, stack_trace) |
480 | | - # if isinstance(agent, TapeAgent): |
481 | | - # task = getattr(env, "task", {}) |
482 | | - # save_tape(self.exp_dir, episode_info, task, agent.final_tape) |
| 476 | + if isinstance(agent, TapeAgent): |
| 477 | + task = getattr(env, "task", {}) |
| 478 | + save_tape(self.exp_dir, episode_info, task, agent.final_tape) |
483 | 479 | except Exception as e: |
484 | 480 | logger.exception(f"Error while saving experiment info: {e}") |
485 | 481 | try: |
|
0 commit comments