From c2bb91f84af8c17870f5e8d36f8a85ddb09df347 Mon Sep 17 00:00:00 2001 From: Wesley Pettit Date: Mon, 12 Jun 2023 22:50:06 -0700 Subject: [PATCH] load-test: differentiate task ARNs for each input logger Signed-off-by: Wesley Pettit --- load_tests/load_test.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/load_tests/load_test.py b/load_tests/load_test.py index 4b44d40f2..4d76376db 100644 --- a/load_tests/load_test.py +++ b/load_tests/load_test.py @@ -212,7 +212,8 @@ def run_ecs_tests(): launchType='EC2', taskDefinition=f'{PREFIX}{OUTPUT_PLUGIN}-{throughput}-{input_logger["name"]}' ) - names[f'{OUTPUT_PLUGIN}_{throughput}_task_arn'] = response['tasks'][0]['taskArn'] + print(f'run_task_response={response}') + names[f'{OUTPUT_PLUGIN}_{input_logger["name"]}_{throughput}_task_arn'] = response['tasks'][0]['taskArn'] # Validation input type banner print(f'\nTest {input_logger["name"]} to {OUTPUT_PLUGIN} in progress...') @@ -226,7 +227,7 @@ def run_ecs_tests(): session = get_sts_boto_session() client = session.client('ecs') waiter = client.get_waiter('tasks_stopped') - task_arn = names[f'{OUTPUT_PLUGIN}_{throughput}_task_arn'] + task_arn = names[f'{OUTPUT_PLUGIN}_{input_logger["name"]}_{throughput}_task_arn'] waiter.wait( cluster=ecs_cluster_name, tasks=[