From 3fadd7f140ba64c681fb8f0a311120c85793f267 Mon Sep 17 00:00:00 2001 From: nate nowack Date: Wed, 9 Oct 2024 12:09:03 -0500 Subject: [PATCH] make task creation and submission logs `DEBUG` (#15631) --- src/prefect/task_engine.py | 4 ++-- src/prefect/task_runners.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/prefect/task_engine.py b/src/prefect/task_engine.py index 88b61c1e2886..36388fd05756 100644 --- a/src/prefect/task_engine.py +++ b/src/prefect/task_engine.py @@ -658,7 +658,7 @@ def initialize_run( with self.setup_run_context(): # setup_run_context might update the task run name, so log creation here - self.logger.info( + self.logger.debug( f"Created task run {self.task_run.name!r} for task {self.task.name!r}" ) yield self @@ -1167,7 +1167,7 @@ async def initialize_run( async with self.setup_run_context(): # setup_run_context might update the task run name, so log creation here - self.logger.info( + self.logger.debug( f"Created task run {self.task_run.name!r} for task {self.task.name!r}" ) yield self diff --git a/src/prefect/task_runners.py b/src/prefect/task_runners.py index 90b62d099b68..3e3e7f46aeb5 100644 --- a/src/prefect/task_runners.py +++ b/src/prefect/task_runners.py @@ -278,11 +278,11 @@ def submit( flow_run_ctx = FlowRunContext.get() if flow_run_ctx: - get_run_logger(flow_run_ctx).info( + get_run_logger(flow_run_ctx).debug( f"Submitting task {task.name} to thread pool executor..." ) else: - self.logger.info(f"Submitting task {task.name} to thread pool executor...") + self.logger.debug(f"Submitting task {task.name} to thread pool executor...") submit_kwargs = dict( task=task,