googleapis
diff --git a/Collapse file
‎packages/bigframes/bigframes/session/__init__.py‎
Copy file name to clipboardExpand all lines: packages/bigframes/bigframes/session/__init__.py
+34-23Lines changed: 34 additions & 23 deletions b/Collapse file
‎packages/bigframes/bigframes/session/__init__.py‎
Copy file name to clipboardExpand all lines: packages/bigframes/bigframes/session/__init__.py
+34-23Lines changed: 34 additions & 23 deletions
diff --git a/Collapse file
‎packages/bigframes/bigframes/session/bq_caching_executor.py‎
Copy file name to clipboardExpand all lines: packages/bigframes/bigframes/session/bq_caching_executor.py
+3-2Lines changed: 3 additions & 2 deletions b/Collapse file
‎packages/bigframes/bigframes/session/bq_caching_executor.py‎
Copy file name to clipboardExpand all lines: packages/bigframes/bigframes/session/bq_caching_executor.py
+3-2Lines changed: 3 additions & 2 deletions
@@ -188,39 +188,50 @@ def __init__(
         if context is None:
             context = bigquery_options.BigQueryOptions()
 
-        if context.location is None:
-            self._location = "US"
-            msg = bfe.format_message(
-                f"No explicit location is set, so using location {self._location} for the session."
-            )
-            # User's code
-            # -> get_global_session()
-            # -> connect()
-            # -> Session()
-            #
-            # Note: We could also have:
-            # User's code
-            # -> read_gbq()
-            # -> with_default_session()
-            # -> get_global_session()
-            # -> connect()
-            # -> Session()
-            # but we currently have no way to disambiguate these
-            # situations.
-            warnings.warn(msg, stacklevel=4, category=bfe.DefaultLocationWarning)
-        else:
-            self._location = context.location
-
         self._bq_kms_key_name = context.kms_key_name
 
         # Instantiate a clients provider to help with cloud clients that will be
         # used in the future operations in the session
         if clients_provider:
+            # this path is only for unit testing. Not meant to be used by end users.
             self._clients_provider = clients_provider
+            self._location = context.location or "US"
         else:
             credentials, project = (
                 bigframes._config.auth.resolve_credentials_and_project(context)
             )
+            if context.location is None:
+                with bigquery.Client(
+                    project=project,
+                    credentials=credentials,
+                ) as temp_client:
+                    row_iter = temp_client.query_and_wait(
+                        "SELECT 1",
+                        job_config=bigquery.QueryJobConfig(dry_run=True),
+                    )
+                    self._location = row_iter.location or "US"
+                    msg = bfe.format_message(
+                        f"No explicit location is set, so using location {self._location} for the session."
+                    )
+                    # User's code
+                    # -> get_global_session()
+                    # -> connect()
+                    # -> Session()
+                    #
+                    # Note: We could also have:
+                    # User's code
+                    # -> read_gbq()
+                    # -> with_default_session()
+                    # -> get_global_session()
+                    # -> connect()
+                    # -> Session()
+                    # but we currently have no way to disambiguate these
+                    # situations.
+                    warnings.warn(
+                        msg, stacklevel=4, category=bfe.DefaultLocationWarning
+                    )
+            else:
+                self._location = context.location
 
             self._clients_provider = clients.ClientsProvider(
                 project=project,
 
@@ -547,8 +547,9 @@ def _cache_most_complex_subtree(self, node: nodes.BigFrameNode) -> bool:
             max_complexity=QUERY_COMPLEXITY_LIMIT,
             cache=self.cache,
             # Heuristic: subtree_compleixty * (copies of subtree)^2
-            heuristic=lambda complexity, count: math.log(complexity)
-            + 2 * math.log(count),
+            heuristic=lambda complexity, count: (
+                math.log(complexity) + 2 * math.log(count)
+            ),
         )
         if selection is None:
             # No good subtrees to cache, just return original tree