googleapis
diff --git a/Collapse file
‎bigframes/bigquery/_operations/ai.py‎
Copy file name to clipboardExpand all lines: bigframes/bigquery/_operations/ai.py
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎bigframes/bigquery/_operations/ai.py‎
Copy file name to clipboardExpand all lines: bigframes/bigquery/_operations/ai.py
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎bigframes/functions/_function_session.py‎
Copy file name to clipboardExpand all lines: bigframes/functions/_function_session.py
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎bigframes/functions/_function_session.py‎
Copy file name to clipboardExpand all lines: bigframes/functions/_function_session.py
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎bigframes/operations/blob.py‎
Copy file name to clipboardExpand all lines: bigframes/operations/blob.py
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎bigframes/operations/blob.py‎
Copy file name to clipboardExpand all lines: bigframes/operations/blob.py
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎bigframes/session/__init__.py‎
Copy file name to clipboardExpand all lines: bigframes/session/__init__.py
+11-1Lines changed: 11 additions & 1 deletion b/Collapse file
‎bigframes/session/__init__.py‎
Copy file name to clipboardExpand all lines: bigframes/session/__init__.py
+11-1Lines changed: 11 additions & 1 deletion
@@ -1018,7 +1018,7 @@ def _convert_series(
 
 def _resolve_connection_id(series: series.Series, connection_id: str | None):
     return clients.get_canonical_bq_connection_id(
-        connection_id or series._session._bq_connection,
+        connection_id or series._session.bq_connection,
         series._session._project,
         series._session._location,
     )
 
@@ -162,7 +162,7 @@ def _resolve_bigquery_connection_id(
     ) -> str:
         """Resolves BigQuery connection id."""
         if not bigquery_connection:
-            bigquery_connection = session._bq_connection  # type: ignore
+            bigquery_connection = session.bq_connection  # type: ignore
 
         bigquery_connection = clients.get_canonical_bq_connection_id(
             bigquery_connection,
 
@@ -311,7 +311,7 @@ def _resolve_connection(self, connection: Optional[str] = None) -> str:
         Raises:
             ValueError: If the connection cannot be resolved to a valid string.
         """
-        connection = connection or self._data._block.session._bq_connection
+        connection = connection or self._data._block.session.bq_connection
         return clients.get_canonical_bq_connection_id(
             connection,
             default_project=self._data._block.session._project,
 
@@ -374,6 +374,16 @@ def _allows_ambiguity(self) -> bool:
     def _anonymous_dataset(self):
         return self._anon_dataset_manager.dataset
 
+    @property
+    def bq_connection(self) -> str:
+        msg = bfe.format_message(
+            f"""You are using the BigFrames session default connection: {self._bq_connection},
+            which can be different from the BigQuery project default connection.
+            This default connection may change in the future."""
+        )
+        warnings.warn(msg, category=FutureWarning)
+        return self._bq_connection
+
     def __hash__(self):
         # Stable hash needed to use in expression tree
         return hash(str(self._session_id))
@@ -2253,7 +2263,7 @@ def _create_bq_connection(
     ) -> str:
         """Create the connection with the session settings and try to attach iam role to the connection SA.
         If any of project, location or connection isn't specified, use the session defaults. Returns fully-qualified connection name."""
-        connection = self._bq_connection if not connection else connection
+        connection = self.bq_connection if not connection else connection
         connection = bigframes.clients.get_canonical_bq_connection_id(
             connection_id=connection,
             default_project=self._project,
Original file line number	Diff line number	Diff line change
`@@ -1018,7 +1018,7 @@ def _convert_series(`
`1018`	`1018`
`1019`	`1019`	`def _resolve_connection_id(series: series.Series, connection_id: str \| None):`
`1020`	`1020`	`return clients.get_canonical_bq_connection_id(`
`1021`		`- connection_id or series._session._bq_connection,`
	`1021`	`+ connection_id or series._session.bq_connection,`
`1022`	`1022`	`series._session._project,`
`1023`	`1023`	`series._session._location,`
`1024`	`1024`	`)`