Skip to content

Commit

Permalink
make task creation and submission logs DEBUG (#15631)
Browse files Browse the repository at this point in the history
  • Loading branch information
zzstoatzz authored Oct 9, 2024
1 parent b1c9d20 commit 3fadd7f
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions src/prefect/task_engine.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions src/prefect/task_runners.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit 3fadd7f

Please sign in to comment.