From 77db5e2a2b3ff79fb5504d4f05a1005a1c6fb3ef Mon Sep 17 00:00:00 2001 From: Alex Thomas Date: Fri, 16 Aug 2024 15:22:42 +0100 Subject: [PATCH] Reverted TaskPipelineNode logger call to debug --- src/neo4j_genai/experimental/pipeline/pipeline.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/neo4j_genai/experimental/pipeline/pipeline.py b/src/neo4j_genai/experimental/pipeline/pipeline.py index c9372b2f0..b37b964cd 100644 --- a/src/neo4j_genai/experimental/pipeline/pipeline.py +++ b/src/neo4j_genai/experimental/pipeline/pipeline.py @@ -119,8 +119,7 @@ async def execute(self, **kwargs: Any) -> RunResult | None: if the task run successfully, None if the status update was unsuccessful. """ - logger.info(f"Running component {self.name}") - logger.debug(f"Component {self.name} arguments: {kwargs}") + logger.debug(f"Running component {self.name} with {kwargs}") start_time = default_timer() try: await self.set_status(RunStatus.RUNNING) @@ -134,7 +133,7 @@ async def execute(self, **kwargs: Any) -> RunResult | None: result=component_result, ) end_time = default_timer() - logger.info(f"Component {self.name} finished in {end_time - start_time}s") + logger.debug(f"Component {self.name} finished in {end_time - start_time}s") return run_result def validate_inputs_config(self, input_data: dict[str, Any]) -> None: