@@ -746,7 +746,7 @@ def _handle_staging_operation(
746
746
session_id_hex = self .connection .get_session_id_hex (),
747
747
)
748
748
749
- @log_latency ()
749
+ @log_latency (StatementType . SQL )
750
750
def _handle_staging_put (
751
751
self , presigned_url : str , local_file : str , headers : Optional [dict ] = None
752
752
):
@@ -786,7 +786,7 @@ def _handle_staging_put(
786
786
+ "but not yet applied on the server. It's possible this command may fail later."
787
787
)
788
788
789
- @log_latency ()
789
+ @log_latency (StatementType . SQL )
790
790
def _handle_staging_get (
791
791
self , local_file : str , presigned_url : str , headers : Optional [dict ] = None
792
792
):
@@ -814,7 +814,7 @@ def _handle_staging_get(
814
814
with open (local_file , "wb" ) as fp :
815
815
fp .write (r .content )
816
816
817
- @log_latency ()
817
+ @log_latency (StatementType . SQL )
818
818
def _handle_staging_remove (
819
819
self , presigned_url : str , headers : Optional [dict ] = None
820
820
):
@@ -828,7 +828,7 @@ def _handle_staging_remove(
828
828
session_id_hex = self .connection .get_session_id_hex (),
829
829
)
830
830
831
- @log_latency (StatementType .SQL )
831
+ @log_latency (StatementType .QUERY )
832
832
def execute (
833
833
self ,
834
834
operation : str ,
@@ -919,7 +919,7 @@ def execute(
919
919
920
920
return self
921
921
922
- @log_latency (StatementType .SQL )
922
+ @log_latency (StatementType .QUERY )
923
923
def execute_async (
924
924
self ,
925
925
operation : str ,
0 commit comments