We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1400ba5 commit 71b76c8Copy full SHA for 71b76c8
dbos/_outcome.py
@@ -16,6 +16,7 @@
16
17
from dbos._context import EnterDBOSStepRetry
18
from dbos._error import DBOSException
19
+from dbos._logger import dbos_logger
20
from dbos._registrations import get_dbos_func_name
21
22
if TYPE_CHECKING:
@@ -184,6 +185,9 @@ async def _wrap(
184
185
try:
186
value = await func()
187
return await asyncio.to_thread(after, lambda: value)
188
+ except asyncio.CancelledError:
189
+ dbos_logger.warning(f"Asyncio task cancelled for workflow or step {func}")
190
+ raise
191
except BaseException as exp:
192
return await asyncio.to_thread(after, lambda: Pending._raise(exp))
193
0 commit comments