From 1add0b98107307c11240d470cc085293b182f1b6 Mon Sep 17 00:00:00 2001 From: Kevin Grismore <146098880+kevingrismore@users.noreply.github.com> Date: Tue, 12 Mar 2024 13:54:01 -0500 Subject: [PATCH] Call existing function for getting recent revision from family (#393) --- 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(