fix(py-sdk): handle Taskiq dependencies

ApeWorX · Oct 3, 2024 · 4c9ad42 · 4c9ad42
1 parent f3b133b
commit 4c9ad42
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sdk/py/apepay/manager.py b/sdk/py/apepay/manager.py
@@ -214,8 +214,8 @@ def decorator(f):
 
             @app.on_(container)
             @wraps(f)
-            def inner(log):
-                return f(Stream(manager=self, id=log.stream_id))
+            def inner(log, **dependencies):
+                return f(Stream(manager=self, id=log.stream_id), **dependencies)
 
             return inner