Skip to content

Commit

Permalink
Fix some log messages.
Browse files Browse the repository at this point in the history
  • Loading branch information
plypaul committed Dec 12, 2024
1 parent 8ece79f commit d09970f
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ def __init__(self, left_branch_node: DataflowPlanNode) -> None: # noqa: D107
self._current_left_node: DataflowPlanNode = left_branch_node

def _log_visit_node_type(self, node: DataflowPlanNode) -> None:
logger.debug(lambda: f"Visiting {node.node_id}")
logger.debug(LazyFormat(lambda: f"Visiting {node.node_id}"))

def _log_combine_failure(
self,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -280,7 +280,14 @@ def visit_combine_aggregated_outputs_node( # noqa: D102
for branch_combination_result in combination_results
]

logger.debug(lambda: f"Got {len(combined_parent_branches)} branches after combination")
logger.debug(
LazyFormat(
"Possible branches combined.",
count_of_branches_before_combination=len(optimized_parent_branches),
count_of_branches_after_combination=len(combined_parent_branches),
)
)

assert len(combined_parent_branches) > 0

# If we were able to reduce the parent branches of the CombineAggregatedOutputsNode into a single one, there's
Expand Down

0 comments on commit d09970f

Please sign in to comment.