diff --git a/prefect_aws/workers/ecs_worker.py b/prefect_aws/workers/ecs_worker.py index 64d206e5..da2382e7 100644 --- a/prefect_aws/workers/ecs_worker.py +++ b/prefect_aws/workers/ecs_worker.py @@ -675,7 +675,7 @@ def _create_task_and_wait_for_start( _TASK_DEFINITION_CACHE[flow_run.deployment_id] = task_definition_arn logger.info(f"Using ECS task definition {task_definition_arn!r}...") - logger.debug(f"Task definition {json.dumps(task_definition, indent=2)}") + logger.debug(f"Task definition {json.dumps(task_definition, indent=2, default=str)}") # Prepare the task run request task_run_request = self._prepare_task_run_request( @@ -686,7 +686,7 @@ def _create_task_and_wait_for_start( ) logger.info("Creating ECS task run...") - logger.debug(f"Task run request {json.dumps(task_run_request, indent=2)}") + logger.debug(f"Task run request {json.dumps(task_run_request, indent=2, default=str)}") try: task = self._create_task_run(ecs_client, task_run_request) task_arn = task["taskArn"] @@ -861,7 +861,7 @@ def _register_task_definition( Returns the ARN. """ logger.info("Registering ECS task definition...") - logger.debug(f"Task definition request {json.dumps(task_definition, indent=2)}") + logger.debug(f"Task definition request {json.dumps(task_definition, indent=2, default=str)}") response = ecs_client.register_task_definition(**task_definition) return response["taskDefinition"]["taskDefinitionArn"]