(self)
| 253 | pass |
| 254 | |
| 255 | def setup_engine_remote(self): |
| 256 | return self.collective_rpc("setup_engine", non_block=False) |
| 257 | |
| 258 | async def setup_engine_remote_async(self): |
| 259 | """Async version of setup_engine_remote for use after async worker initialization.""" |
no test coverage detected