(self, e: Executor, a: "Action")
| 62 | raise NotImplementedError |
| 63 | |
| 64 | def start_initialize(self, e: Executor, a: "Action") -> None: |
| 65 | if self._can_run(e) and self.enabled: |
| 66 | self.current_version = e.current_mz_version |
| 67 | self._initialize = self.initialize() |
| 68 | self._initialize.execute(e, a.mz_service) |
| 69 | |
| 70 | def join_initialize(self, e: Executor) -> None: |
| 71 | if self._can_run(e) and self.enabled: |
no test coverage detected