File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -220,8 +220,8 @@ async def _find_previous_query_id( # type: ignore[override]
220220 break
221221 if (
222222 execution .query == query
223- and ( self . _schema_name is None or execution .database == self ._schema_name )
224- and ( self . _catalog_name is None or execution .catalog == self ._catalog_name )
223+ and execution .database == self ._schema_name
224+ and execution .catalog == self ._catalog_name
225225 ):
226226 query_id = execution .query_id
227227 break
Original file line number Diff line number Diff line change @@ -640,8 +640,8 @@ def _find_previous_query_id(
640640 break
641641 if (
642642 execution .query == query
643- and ( self . _schema_name is None or execution .database == self ._schema_name )
644- and ( self . _catalog_name is None or execution .catalog == self ._catalog_name )
643+ and execution .database == self ._schema_name
644+ and execution .catalog == self ._catalog_name
645645 ):
646646 query_id = execution .query_id
647647 break
You can’t perform that action at this time.
0 commit comments