From 9a35b47e01ffe8f1fec41cbc2b04ce209984a164 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= <sybren@stuvel.eu>
Date: Mon, 14 Jan 2019 11:20:09 +0100
Subject: [PATCH] Prevent uncaught CancelledError to force an awakening of the
Worker
---
flamenco_worker/worker.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/flamenco_worker/worker.py b/flamenco_worker/worker.py
index 0c149648..9e65c6f6 100644
--- a/flamenco_worker/worker.py
+++ b/flamenco_worker/worker.py
@@ -312,6 +312,9 @@ class FlamencoWorker:
if ex is None:
return
+ if isinstance(ex, asyncio.CancelledError):
+ return
+
self._log.error('Unhandled %s running single iteration: %s', type(ex).__name__, ex)
self._log.error('Bluntly going to reschedule another iteration in %d seconds',
UNCAUGHT_EXCEPTION_RETRY_DELAY)
--
GitLab