Merge branch 'main' into librarian-20260612T171649Z

Author: sofisl

.librarian/config.yaml

@@ -38,5 +38,3 @@ libraries:
   # TODO(https://github.com/googleapis/google-cloud-python/issues/17327)
   - id: "google-cloud-bigtable"
     release_blocked: true
-
-

.librarian/state.yaml

@@ -14,7 +14,7 @@
 image: us-central1-docker.pkg.dev/cloud-sdk-librarian-prod/images-prod/python-librarian-generator@sha256:234b9d1f2ddb057ed7ac6a38db0bf8163d839c65c6cf88ade52530cddebce59e
 libraries:
   - id: bigframes
-    version: 2.42.0
+    version: 2.43.0
     last_generated_commit: ""
     apis: []
     source_roots:

librarian.yaml

@@ -58,7 +58,7 @@ default:
     library_type: GAPIC_AUTO
 libraries:
   - name: bigframes
-    version: 2.42.0
+    version: 2.43.0
     skip_release: true
     python:
       library_type: INTEGRATION

packages/bigframes/CHANGELOG.md

@@ -4,6 +4,25 @@
 
 [1]: https://pypi.org/project/bigframes/#history
 
+## [2.43.0](https://github.com/googleapis/google-cloud-python/compare/bigframes-v2.42.0...bigframes-v2.43.0) (2026-06-12)
+
+
+### Documentation
+
+* add a notebook explaining bqsql magics cell chaining (#17216) ([1a0de4a7701b7fdf4c2593b1960f1194ebc49793](https://github.com/googleapis/google-cloud-python/commit/1a0de4a7701b7fdf4c2593b1960f1194ebc49793))
+
+
+### Features
+
+* add `bigframes.bigquery.bit_count` and conversion scalar function (#17433) ([7f29823fadb3cff42dbe666f8c7aa33bab3c7021](https://github.com/googleapis/google-cloud-python/commit/7f29823fadb3cff42dbe666f8c7aa33bab3c7021))
+
+
+### Bug Fixes
+
+* preserve aliases on cast columns and fix star selection in sqlglot (#17394) (#17455) ([145034a345eb3e14ea3f23dfcafa3d2409a09067](https://github.com/googleapis/google-cloud-python/commit/145034a345eb3e14ea3f23dfcafa3d2409a09067))
+* bump pyarrow from 15.0.2 to 23.0.1 in /packages/bigframes (#17386) ([f59c2b2aa61316cf04b650933036ef50f6a1f08c](https://github.com/googleapis/google-cloud-python/commit/f59c2b2aa61316cf04b650933036ef50f6a1f08c))
+* improve error message when unescaped `{` are found in SQL cells (#17346) ([3a90cc8e867c8a2d2f8060858fde9eda94f80a54](https://github.com/googleapis/google-cloud-python/commit/3a90cc8e867c8a2d2f8060858fde9eda94f80a54))
+
 ## [2.42.0](https://github.com/googleapis/google-cloud-python/compare/bigframes-v2.41.0...bigframes-v2.42.0) (2026-06-08)
 
 

packages/bigframes/bigframes/core/compile/sqlglot/sqlglot_ir.py

@@ -249,12 +249,13 @@ def select(
         # TODO: Explicitly insert CTEs into plan
         if len(selections) > 0:
             to_select = [
-                sge.Alias(
-                    this=expr,
+                expr
+                if (isinstance(expr, sge.Alias) and expr.alias == id)
+                or (isinstance(expr, sge.Column) and expr.name == id)
+                else sge.Alias(
+                    this=expr.this if isinstance(expr, sge.Alias) else expr,
                     alias=sql.identifier(id),
                 )
-                if expr.alias_or_name != id
-                else expr
                 for id, expr in selections
             ]
             new_expr = self.expr.select(*to_select)

packages/bigframes/bigframes/core/sql_nodes.py

@@ -276,7 +276,14 @@ def _node_expressions(self):
 
     @property
     def is_star_selection(self) -> bool:
-        return tuple(self.ids) == tuple(self.child.ids)
+        if tuple(self.ids) != tuple(self.child.ids):
+            return False
+        for cdef in self.selections:
+            if not isinstance(cdef.expression, ex.DerefOp):
+                return False
+            if cdef.expression.id != cdef.id:
+                return False
+        return True
 
     @functools.cache
     def get_id_mapping(self) -> dict[identifiers.ColumnId, ex.Expression]:

packages/bigframes/bigframes/session/anonymous_dataset.py

@@ -16,6 +16,7 @@
 import threading
 import uuid
 import warnings
+from concurrent.futures import ThreadPoolExecutor
 from typing import List, Optional, Sequence
 
 import google.cloud.bigquery as bigquery
@@ -170,9 +171,19 @@ def _cleanup_old_udfs(self):
 
     def close(self):
         """Delete tables that were created with this session's session_id."""
-        for table_ref in self._table_ids:
-            self.bqclient.delete_table(table_ref, not_found_ok=True)
-        self._table_ids.clear()
+        if self._table_ids:
+            try:
+                with ThreadPoolExecutor() as executor:
+                    futures = [
+                        executor.submit(
+                            self.bqclient.delete_table, table_ref, not_found_ok=True
+                        )
+                        for table_ref in self._table_ids
+                    ]
+                    for future in futures:
+                        future.result()
+            finally:
+                self._table_ids.clear()
 
         try:
             # Before closing the session, attempt to clean up any uncollected,

packages/bigframes/bigframes/version.py

@@ -12,8 +12,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-__version__ = "2.42.0"
+__version__ = "2.43.0"
 
 # {x-release-please-start-date}
-__release_date__ = "2026-06-08"
+__release_date__ = "2026-06-12"
 # {x-release-please-end}

packages/bigframes/noxfile.py

@@ -354,6 +354,7 @@ def run_system(
         "py.test",
         "-v",
         f"-n={num_workers}",
+        "--dist=worksteal",
         # Any individual test taking longer than 15 mins will be terminated.
         f"--timeout={timeout_seconds}",
         # Log 20 slowest tests

packages/bigframes/release-procedure.md

@@ -0,0 +1,51 @@
+# BigQuery DataFrames (bigframes) release procedure
+
+*(Note: bigframes releases are marked with `skip_release: true` in `librarian.yaml` and must be kicked off manually using legacylibrarian.)*
+
+## Setup (First Time Only)
+
+*   Install `legacylibrarian`:
+
+        go install github.com/googleapis/librarian/cmd/legacylibrarian@latest
+
+*   Authenticate with GitHub CLI:
+
+        gh auth login
+
+## Release Steps
+
+*   Obtain GitHub token:
+
+        export LIBRARIAN_GITHUB_TOKEN=$(gh auth token)
+
+*   Stash changes (repo must be clean):
+
+        git stash -u
+
+*   Fetch and checkout base:
+
+        git fetch origin main
+        git fetch origin --tags
+        git checkout origin/main
+
+*   Check image updates:
+
+        legacylibrarian update-image --push
+
+*   Create release PR:
+
+        # Option A: Push directly
+        legacylibrarian release stage --repo=https://github.com/googleapis/google-cloud-python --library=bigframes --library-version=X.X.X --push
+
+        # Option B: Manual edit first (omit --push, edit files in /tmp/librarian-*, commit/push from there)
+        legacylibrarian release stage --repo=https://github.com/googleapis/google-cloud-python --library=bigframes --library-version=X.X.X
+        # In /tmp repository:
+        git commit -a -m "chore: create release" --no-verify  # keep librarian config pristine
+        git push origin HEAD
+        gh pr create --fill --label "release:pending"
+
+*   Post-release restore:
+
+        # Move back any stashed/relocated files (like .vscode)
+        git checkout main
+        git stash pop