File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -735,8 +735,7 @@ def __init__(
735
735
sql : str ,
736
736
legacy_primitive_types : bool = False ,
737
737
) -> None :
738
- self .query_id : Optional [str ] = None
739
-
738
+ self ._query_id : Optional [str ] = None
740
739
self ._stats : Dict [Any , Any ] = {}
741
740
self ._info_uri : Optional [str ] = None
742
741
self ._warnings : List [Dict [Any , Any ]] = []
@@ -752,6 +751,10 @@ def __init__(
752
751
self ._legacy_primitive_types = legacy_primitive_types
753
752
self ._row_mapper : Optional [RowMapper ] = None
754
753
754
+ @property
755
+ def query_id (self ) -> Optional [str ]:
756
+ return self ._query_id
757
+
755
758
@property
756
759
def columns (self ):
757
760
if self .query_id :
@@ -799,7 +802,7 @@ def execute(self, additional_http_headers=None) -> TrinoResult:
799
802
response = self ._request .post (self ._sql , additional_http_headers )
800
803
status = self ._request .process (response )
801
804
self ._info_uri = status .info_uri
802
- self .query_id = status .id
805
+ self ._query_id = status .id
803
806
self ._stats .update ({"queryId" : self .query_id })
804
807
self ._update_state (status )
805
808
self ._warnings = getattr (status , "warnings" , [])
You can’t perform that action at this time.
0 commit comments