dont break on debug logs

PrefectHQ · Jul 12, 2023 · cc19b15 · cc19b15
1 parent 917f452
commit cc19b15
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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"]