Commit b51ad7b
authored
chore: remove google-cloud-bigquery from bulk release due to failing system test (#17944)
Temporarily remove `google-cloud-bigquery` from the bulk release due to
this system test failure
```
=================================== FAILURES ===================================
___________ TestBigQuery.test_dbapi_connection_does_not_leak_sockets ___________
[gw1] linux -- Python 3.12.12 /tmpfs/src/github/google-cloud-python/packages/google-cloud-bigquery/.nox/system-3-12/bin/python
self =
def test_dbapi_connection_does_not_leak_sockets(self):
pytest.importorskip("google.cloud.bigquery_storage")
current_process = psutil.Process()
conn_start = current_process.net_connections()
conn_count_start = len(conn_start)
with helpers.patch_tracked_requests():
# Provide no explicit clients, so that the connection will create and own them.
connection = dbapi.connect()
cursor = connection.cursor()
cursor.execute(
"""
SELECT id, `by`, timestamp
FROM `bigquery-public-data.hacker_news.full`
ORDER BY `id` ASC
LIMIT 100000
"""
)
rows = cursor.fetchall()
self.assertEqual(len(rows), 100000)
connection.close()
import gc
gc.collect()
for _ in range(30): # Wait up to 3 seconds
conn_end = current_process.net_connections()
conn_count_end = len(conn_end)
if conn_count_end <= conn_count_start:
break
time.sleep(0.1)
try:
> self.assertLessEqual(conn_count_end, conn_count_start)
E AssertionError: 7 not less than or equal to 6
tests/system/test_client.py:2217: AssertionError
During handling of the above exception, another exception occurred:
self =
def test_dbapi_connection_does_not_leak_sockets(self):
pytest.importorskip("google.cloud.bigquery_storage")
current_process = psutil.Process()
conn_start = current_process.net_connections()
conn_count_start = len(conn_start)
with helpers.patch_tracked_requests():
# Provide no explicit clients, so that the connection will create and own them.
connection = dbapi.connect()
cursor = connection.cursor()
cursor.execute(
"""
SELECT id, `by`, timestamp
FROM `bigquery-public-data.hacker_news.full`
ORDER BY `id` ASC
LIMIT 100000
"""
)
rows = cursor.fetchall()
self.assertEqual(len(rows), 100000)
connection.close()
import gc
gc.collect()
for _ in range(30): # Wait up to 3 seconds
conn_end = current_process.net_connections()
conn_count_end = len(conn_end)
if conn_count_end <= conn_count_start:
break
time.sleep(0.1)
try:
self.assertLessEqual(conn_count_end, conn_count_start)
except AssertionError as e:
# Due to flakiness in this test (likely caused by OS cleanup delays or
# non-deterministic garbage collection of sockets), we want to capture
# the detailed state of connections in future failing runs to help
# decrease false positives and identify the root cause.
conn_debug = [
f"Status: {c.status}, Laddr: {c.laddr}, Raddr: {c.raddr}"
for c in current_process.net_connections()
]
debug_msg = "\n".join(conn_debug)
> raise AssertionError(
f"{e}\n\n"
f"--- Socket Leak Debug Info ---\n"
f"Start Count: {conn_count_start}\n"
f"End Count: {conn_count_end}\n"
f"Current Connections:\n{debug_msg}"
)
E AssertionError: 7 not less than or equal to 6
E
E --- Socket Leak Debug Info ---
E Start Count: 6
E End Count: 7
E Current Connections:
....
tests/system/test_client.py:2229: AssertionError
=========================== short test summary info ============================
FAILED tests/system/test_client.py::TestBigQuery::test_dbapi_connection_does_not_leak_sockets
```1 parent d267342 commit b51ad7b
4 files changed
Lines changed: 4 additions & 4 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
54 | 54 | | |
55 | 55 | | |
56 | 56 | | |
57 | | - | |
58 | 57 | | |
59 | 58 | | |
60 | 59 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
| 3 | + | |
3 | 4 | | |
4 | 5 | | |
5 | 6 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
653 | 653 | | |
654 | 654 | | |
655 | 655 | | |
656 | | - | |
657 | | - | |
658 | | - | |
659 | 656 | | |
660 | 657 | | |
661 | 658 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
5 | 5 | | |
6 | 6 | | |
7 | 7 | | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
8 | 11 | | |
9 | 12 | | |
10 | 13 | | |
| |||
0 commit comments