@@ -84,6 +84,17 @@ def _inner(*args: "P.args", **kwargs: "P.kwargs") -> "T":
8484 query_id = args [2 ] if len (args ) > 2 else kwargs .get ("query_id" )
8585 params = args [3 ] if len (args ) > 3 else kwargs .get ("params" )
8686
87+ connection ._query = query
88+ connection ._breadcrumb_data = {
89+ SPANDATA .DB_SYSTEM : "clickhouse" ,
90+ SPANDATA .DB_NAME : connection .database ,
91+ SPANDATA .DB_DRIVER_NAME : "clickhouse-driver" ,
92+ SPANDATA .SERVER_ADDRESS : connection .host ,
93+ SPANDATA .SERVER_PORT : connection .port ,
94+ SPANDATA .DB_USER : connection .user ,
95+ "db.params" : params ,
96+ }
97+
8798 if has_span_streaming_enabled (client .options ):
8899 span = None
89100 if sentry_sdk .traces .get_current_span () is not None :
@@ -95,16 +106,6 @@ def _inner(*args: "P.args", **kwargs: "P.kwargs") -> "T":
95106 SPANDATA .DB_QUERY_TEXT : str (query ),
96107 },
97108 )
98-
99- connection ._query = query
100- connection ._breadcrumb_data = {
101- SPANDATA .DB_SYSTEM : "clickhouse" ,
102- SPANDATA .DB_NAME : connection .database ,
103- SPANDATA .DB_DRIVER_NAME : "clickhouse-driver" ,
104- SPANDATA .SERVER_ADDRESS : connection .host ,
105- SPANDATA .SERVER_PORT : connection .port ,
106- SPANDATA .DB_USER : connection .user ,
107- }
108109 else :
109110 span = sentry_sdk .start_span (
110111 op = OP .DB ,
0 commit comments