Skip to content
Snippets Groups Projects
Commit b152067a authored by Sybren A. Stüvel's avatar Sybren A. Stüvel
Browse files

Added two missing await statements

parent 4814d557
Branches
No related tags found
No related merge requests found
...@@ -444,7 +444,7 @@ class FlamencoWorker: ...@@ -444,7 +444,7 @@ class FlamencoWorker:
elif self._push_act_to_manager is None or self._push_act_to_manager.done(): elif self._push_act_to_manager is None or self._push_act_to_manager.done():
# Schedule a future push to manager. # Schedule a future push to manager.
self._push_act_to_manager = asyncio.ensure_future( 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): async def register_log(self, log_entry, *fmt_args):
"""Registers a log entry, and possibly sends all queued log entries to upstream Manager. """Registers a log entry, and possibly sends all queued log entries to upstream Manager.
...@@ -474,7 +474,7 @@ class FlamencoWorker: ...@@ -474,7 +474,7 @@ class FlamencoWorker:
elif self._push_log_to_manager is None or self._push_log_to_manager.done(): elif self._push_log_to_manager is None or self._push_log_to_manager.done():
# Schedule a future push to manager. # Schedule a future push to manager.
self._push_log_to_manager = asyncio.ensure_future( 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]): def output_produced(self, *paths: typing.Union[str, pathlib.PurePath]):
"""Registers a produced output (e.g. rendered frame) with the manager. """Registers a produced output (e.g. rendered frame) with the manager.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment