From b152067a72da151b9c6d48254dfc9d3c1a1f0b4d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= <sybren@stuvel.eu>
Date: Wed, 6 Sep 2017 17:02:31 +0200
Subject: [PATCH] Added two missing await statements
---
flamenco_worker/worker.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flamenco_worker/worker.py b/flamenco_worker/worker.py
index f8c46ac1..1462b165 100644
--- a/flamenco_worker/worker.py
+++ b/flamenco_worker/worker.py
@@ -444,7 +444,7 @@ class FlamencoWorker:
elif self._push_act_to_manager is None or self._push_act_to_manager.done():
# Schedule a future push to manager.
self._push_act_to_manager = asyncio.ensure_future(
- self.push_to_manager(delay=self.push_act_max_interval))
+ await self.push_to_manager(delay=self.push_act_max_interval))
async def register_log(self, log_entry, *fmt_args):
"""Registers a log entry, and possibly sends all queued log entries to upstream Manager.
@@ -474,7 +474,7 @@ class FlamencoWorker:
elif self._push_log_to_manager is None or self._push_log_to_manager.done():
# Schedule a future push to manager.
self._push_log_to_manager = asyncio.ensure_future(
- self.push_to_manager(delay=self.push_log_max_interval))
+ await self.push_to_manager(delay=self.push_log_max_interval))
def output_produced(self, *paths: typing.Union[str, pathlib.PurePath]):
"""Registers a produced output (e.g. rendered frame) with the manager.
--
GitLab