setattr _is_coroutine

dbos-inc · Jan 31, 2025 · 30fa2e7 · 30fa2e7
1 parent 467efe8
commit 30fa2e7
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dbos/_core.py b/dbos/_core.py
@@ -488,7 +488,9 @@ def start_workflow(
     return WorkflowHandleFuture(new_wf_id, future, dbos)
 
 if sys.version_info <= (3, 11):
+    from asyncio.coroutines import _is_coroutine 
     def mark_coroutine(func: Callable[P, R]) -> Callable[P, R]:
+        setattr(func, '_is_coroutine', _is_coroutine)
         return func
 else:
     def mark_coroutine(func: Callable[P, R]) -> Callable[P, R]: