LOGGER = logging.getLogger("mass.helpers")
-class AsyncProcess(object):
+class AsyncProcess:
"""Implementation of a (truly) non blocking subprocess."""
def __init__(
EVENT_MUSIC_SYNC_STATUS, method_class.running_sync_jobs
)
await func(*args)
- LOGGER.info("Finished syncing %s for provider %s", desc, prov_id)
+ LOGGER.debug("Finished syncing %s for provider %s", desc, prov_id)
method_class.running_sync_jobs.remove(sync_job)
method_class.mass.signal_event(
EVENT_MUSIC_SYNC_STATUS, method_class.running_sync_jobs
await asyncio.wait([fill_buffer_task])
+ # pylint: disable=broad-except
except (
GeneratorExit,
asyncio.CancelledError,
Exception,
- ) as exc: # pylint: disable=broad-except
+ ) as exc:
cancelled = True
fill_buffer_task.cancel()
LOGGER.debug(
async for chunk in sox_proc.iterate_chunks():
yield chunk
await asyncio.wait([fill_buffer_task])
+ # pylint: disable=broad-except
except (
GeneratorExit,
asyncio.CancelledError,
Exception,
- ) as exc: # pylint: disable=broad-except
+ ) as exc:
cancelled = True
fill_buffer_task.cancel()
LOGGER.debug(