From 5d338e944f15fe807bdbebbc0d7bafc5169b8e51 Mon Sep 17 00:00:00 2001 From: Kevin Cameron Grismore Date: Tue, 12 Mar 2024 13:37:46 -0500 Subject: [PATCH] call existing function for getting revision from family --- prefect_aws/workers/ecs_worker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/prefect_aws/workers/ecs_worker.py b/prefect_aws/workers/ecs_worker.py index 2e63eac4..edbe843d 100644 --- a/prefect_aws/workers/ecs_worker.py +++ b/prefect_aws/workers/ecs_worker.py @@ -769,7 +769,7 @@ def _get_or_register_task_definition( ): family_name = task_definition.get("family", ECS_DEFAULT_FAMILY) try: - task_definition_from_family = self._retrieve_task_definition_by_family( + task_definition_from_family = self._retrieve_task_definition( logger, ecs_client, family_name ) if task_definition_from_family and self._task_definitions_equal( @@ -779,7 +779,7 @@ def _get_or_register_task_definition( "taskDefinitionArn" ] except Exception: - pass + cached_task_definition_arn = None if not cached_task_definition_arn: task_definition_arn = self._register_task_definition(