| 160 | |
| 161 | @staticmethod |
| 162 | def collect_executor( |
| 163 | exp: "Experiments", |
| 164 | executor: "BaseExecutor", # noqa: ARG004 |
| 165 | exec_result: "ExecutorResult", |
| 166 | ) -> dict[str, str]: |
| 167 | results: dict[str, str] = {} |
| 168 | exp_rev = exp.scm.get_ref(EXEC_BRANCH) |
| 169 | if exp_rev: |
| 170 | assert exec_result.exp_hash |
| 171 | logger.debug("Collected experiment '%s'.", exp_rev[:7]) |
| 172 | results[exp_rev] = exec_result.exp_hash |
| 173 | |
| 174 | return results |
| 175 | |
| 176 | def get_result(self, entry: QueueEntry) -> Optional["ExecutorResult"]: |
| 177 | raise NotImplementedError |