diff --git a/packages/flamenco-worker-python/flamenco_worker/patch_asyncio.py b/packages/flamenco-worker-python/flamenco_worker/patch_asyncio.py index f4843c6cbc46c9f40b9f39f1d681abe5302e0d4b..3299a3510bb5a658835311f0cb20caf04a2a9db2 100644 --- a/packages/flamenco-worker-python/flamenco_worker/patch_asyncio.py +++ b/packages/flamenco-worker-python/flamenco_worker/patch_asyncio.py @@ -24,6 +24,6 @@ def patch_asyncio(): if not self._loop: return - return orig_resume_reading(*args, **kwargs) + return orig_resume_reading(self, *args, **kwargs) ue._UnixReadPipeTransport.resume_reading = resume_reading