From 3f426a505e0a5293a241b3d6f20afd36aca5b800 Mon Sep 17 00:00:00 2001 From: Giancarlo Romeo Date: Fri, 16 Aug 2024 15:39:33 +0200 Subject: [PATCH] fix async.wait coroutine arg --- .../src/simcore_sdk/node_ports_common/aws_s3_cli.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/packages/simcore-sdk/src/simcore_sdk/node_ports_common/aws_s3_cli.py b/packages/simcore-sdk/src/simcore_sdk/node_ports_common/aws_s3_cli.py index 72ed5b97279..35d1d7c71f8 100644 --- a/packages/simcore-sdk/src/simcore_sdk/node_ports_common/aws_s3_cli.py +++ b/packages/simcore-sdk/src/simcore_sdk/node_ports_common/aws_s3_cli.py @@ -126,7 +126,9 @@ async def _async_aws_cli_command( ) assert proc.stdout # nosec - await asyncio.wait([_read_stream(proc.stdout, [*aws_cli_s3_log_parsers])]) + await asyncio.wait( + [asyncio.create_task(_read_stream(proc.stdout, [*aws_cli_s3_log_parsers]))] + ) _stdout, _stderr = await proc.communicate()