Skip to content

Commit 7963ecd

Browse files
author
s.kazemi
committed
add wait_until_stopped method
1 parent d703045 commit 7963ecd

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)