(self)
| 86 | self.metrics = task.workflow_args.get("metrics", [0]) |
| 87 | |
| 88 | def run(self) -> List[Experience]: |
| 89 | exps = [ |
| 90 | Experience( |
| 91 | eid=EID(run=self.run_id_base, step=step), |
| 92 | tokens=torch.zeros(5), |
| 93 | prompt_length=2, |
| 94 | prompt_text="success", |
| 95 | info={"reset_flag": self.reset_flag}, |
| 96 | metrics={ |
| 97 | "run_metrics": self.metrics[step % len(self.metrics)], |
| 98 | }, |
| 99 | ) |
| 100 | for step in range(self.step_num) |
| 101 | ] |
| 102 | return exps |
| 103 | |
| 104 | |
| 105 | @WORKFLOWS.register_module("dummy_partial_snapshot_workflow") |
nothing calls this directly
no test coverage detected