forked from M-Labs/artiq
1
0
Fork 0

artiq_client: fix deprecated wait usage

This commit is contained in:
Simon Renblad 2024-03-11 12:25:24 +08:00 committed by Sébastien Bourdeauducq
parent 332c9c0fcd
commit 7e6ed1655f
1 changed files with 1 additions and 1 deletions

View File

@ -307,7 +307,7 @@ def _run_subscriber(host, port, subscriber):
loop.run_until_complete(subscriber.connect(host, port)) loop.run_until_complete(subscriber.connect(host, port))
try: try:
_, pending = loop.run_until_complete(asyncio.wait( _, pending = loop.run_until_complete(asyncio.wait(
[signal_handler.wait_terminate(), subscriber.receive_task], [loop.create_task(signal_handler.wait_terminate()), subscriber.receive_task],
return_when=asyncio.FIRST_COMPLETED)) return_when=asyncio.FIRST_COMPLETED))
for task in pending: for task in pending:
task.cancel() task.cancel()