diff --git a/flamenco_worker/patch_asyncio.py b/flamenco_worker/patch_asyncio.py index 3299a3510bb5a658835311f0cb20caf04a2a9db2..1b98d34dabdf7585b0b0717a3244bd31a701e544 100644 --- a/flamenco_worker/patch_asyncio.py +++ b/flamenco_worker/patch_asyncio.py @@ -9,15 +9,19 @@ This prevents an error at the end of a subprocess execution: """ -import asyncio.unix_events as ue - def patch_asyncio(): import logging + import sys log = logging.getLogger(__name__) + if sys.platform == 'win32': + log.debug('Patching ue._UnixReadPipeTransport.resume_reading not needed on Windows') + return + log.debug('Patching ue._UnixReadPipeTransport.resume_reading') + import asyncio.unix_events as ue orig_resume_reading = ue._UnixReadPipeTransport.resume_reading def resume_reading(self, *args, **kwargs):