(self, *args, **kwargs)
| 1239 | return not self.running and self.num_incoming_events <= 0 and self.outgoing_event_queue.qsize() <= 0 |
| 1240 | |
| 1241 | async def run_process(self, *args, **kwargs): |
| 1242 | kwargs["_proc_tracker"] = self._proc_tracker |
| 1243 | return await self.helpers.run(*args, **kwargs) |
| 1244 | |
| 1245 | async def run_process_live(self, *args, **kwargs): |
| 1246 | kwargs["_proc_tracker"] = self._proc_tracker |
no test coverage detected