From 6c1cc0bf9a88785e69c2b9f19da3872a128264d8 Mon Sep 17 00:00:00 2001 From: aewens Date: Sat, 31 Aug 2019 12:48:46 -0500 Subject: [PATCH] Switched to list append for task wait --- event_loop.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/event_loop.py b/event_loop.py index fd09a9d..d3ad4f6 100644 --- a/event_loop.py +++ b/event_loop.py @@ -64,6 +64,7 @@ def test(context, old_value, new_value): return True, status async def main(loop): + tasks = list() queues = dict() queues["hook"] = Queue() queues["push"] = Queue() @@ -72,9 +73,9 @@ async def main(loop): await queues["hook"].put(test) await queues["push"].put(("test", "change", None, True)) - yang = loop.create_task(pull(loop, queues)) - yin = loop.create_task(push(loop, queues)) - await wait([yin, yang]) + tasks.append(loop.create_task(pull(loop, queues))) + tasks.append(loop.create_task(push(loop, queues))) + await wait(tasks) loop.stop() loop = get_event_loop()