|
14 | 14 | # limitations under the License.
|
15 | 15 | from __future__ import annotations
|
16 | 16 |
|
| 17 | +import copy |
17 | 18 | import logging
|
18 | 19 | from typing import Any, Callable, Optional
|
19 | 20 |
|
@@ -193,8 +194,10 @@ def get_search_results(
|
193 | 194 | embedding_node_property=self._embedding_node_property,
|
194 | 195 | neo4j_version_is_5_23_or_above=self.neo4j_version_is_5_23_or_above,
|
195 | 196 | )
|
196 |
| - |
197 |
| - logger.debug("HybridRetriever Cypher parameters: %s", parameters) |
| 197 | + sanitized_parameters = copy.deepcopy(parameters) |
| 198 | + if "query_vector" in sanitized_parameters: |
| 199 | + sanitized_parameters["query_vector"] = "..." |
| 200 | + logger.debug("HybridRetriever Cypher parameters: %s", sanitized_parameters) |
198 | 201 | logger.debug("HybridRetriever Cypher query: %s", search_query)
|
199 | 202 |
|
200 | 203 | records, _, _ = self.driver.execute_query(
|
@@ -348,9 +351,11 @@ def get_search_results(
|
348 | 351 | retrieval_query=self.retrieval_query,
|
349 | 352 | neo4j_version_is_5_23_or_above=self.neo4j_version_is_5_23_or_above,
|
350 | 353 | )
|
351 |
| - |
352 |
| - logger.debug("HybridCypherRetriever Cypher parameters: %s", parameters) |
353 |
| - logger.debug("HybridCypherRetriever Cypher query: %s", search_query) |
| 354 | + sanitized_parameters = copy.deepcopy(parameters) |
| 355 | + if "query_vector" in sanitized_parameters: |
| 356 | + sanitized_parameters["query_vector"] = "..." |
| 357 | + logger.debug("HybridRetriever Cypher parameters: %s", sanitized_parameters) |
| 358 | + logger.debug("HybridRetriever Cypher query: %s", search_query) |
354 | 359 |
|
355 | 360 | records, _, _ = self.driver.execute_query(
|
356 | 361 | search_query, parameters, database_=self.neo4j_database
|
|
0 commit comments