Changed logger level

Author: Liyan Jiang

prefect_aws/ecs.py

@@ -273,8 +273,8 @@ class ECSTask(Infrastructure):
         task_start_timeout_seconds: The amount of time to watch for the
             start of the ECS task before marking it as failed. The task must
             enter a RUNNING state to be considered started.
-        task_finish_timeout_seconds: The amount of time to watch for finishing of the ECS task
-            before marking it as failed.
+        task_finish_timeout_seconds: The amount of time to watch for finishing of the
+            ECS task before marking it as failed.
         task_watch_poll_interval: The amount of time to wait between AWS API
             calls while monitoring the state of an ECS task.
     """
@@ -900,7 +900,7 @@ def _create_task_and_wait_for_start(
             task_arn = task["taskArn"]
             cluster_arn = task["clusterArn"]
         except Exception as exc:
-            self.logger.info(f"EcsTaskException: {exc}")
+            self.logger.error(f"EcsTaskException: {exc}")
             self._report_task_run_creation_failure(task_run, exc)
 
         # Raises an exception if the task does not start
@@ -1129,7 +1129,7 @@ def _watch_task_run(
             else:
                 # Intermittently, the task will not be described. We wat to respect the
                 # watch timeout though.
-                self.logger.debug(f"{self._log_prefix}: Task not found.")
+                self.logger.warning(f"{self._log_prefix}: Task not found.")
 
             elapsed_time = time.time() - t0
             if timeout is not None and elapsed_time > timeout:
@@ -1159,12 +1159,17 @@ def _wait_for_task_start(
                 reason = task.get("stoppedReason")
 
                 containers = task["containers"]
-                exit_codes = " ".join([container.get("exitCode", "?exitCode?") for container in containers])
+                exit_codes = " ".join(
+                    [
+                        container.get("exitCode", "?exitCode?")
+                        for container in containers
+                    ]
+                )
                 try:
                     # Generate a dynamic exception type from the AWS name
                     raise type(code, (RuntimeError,), {})(f"{reason=} {exit_codes=}")
                 except Exception as exc:
-                    self.logger.info(f"EcsTaskException: {exc}")
+                    self.logger.error(f"EcsTaskException: {exc}")
                     raise
 
         return task