Skip to content

Commit 351fe48

Browse files
Merge pull request #80 from negatic/master
add wait_until_stopped method
2 parents b08de17 + 7963ecd commit 351fe48

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

archipy/adapters/temporal/worker.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,10 @@ async def stop(self, grace_period: int = 30) -> None:
173173
},
174174
) from error
175175

176+
async def wait_until_stopped(self) -> None:
177+
"""Wait until the worker is stopped."""
178+
await self._background_task
179+
176180
@property
177181
def is_running(self) -> bool:
178182
"""Check if the worker is currently running.

0 commit comments

Comments
 (0)