Skip to content

Commit a064df3

Browse files
committed
Tighten kernel async handle comments
1 parent 8d31abc commit a064df3

2 files changed

Lines changed: 5 additions & 6 deletions

File tree

tests/e2e/test_kernel_backend.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -417,15 +417,14 @@ def test_dml_rowcount_wiring_does_not_break_dml(conn):
417417
cur.execute(f"DROP TABLE IF EXISTS {tbl}")
418418

419419

420-
# ── Async execution: state + result come from the server (attach-by-id) ──
420+
# ── Async execution: owning handle first, attach-by-id for re-fetch/resume ──
421421

422422

423423
def test_async_execute_polls_and_fetches_result(conn):
424424
"""The full async CUJ: ``execute_async`` → poll
425-
``get_query_state`` → ``get_async_execution_result``. State comes
426-
from the server by re-attaching to the statement id; first
427-
in-process result fetch uses the retained owning handle so kernel
428-
async telemetry is finalized."""
425+
``get_query_state`` → ``get_async_execution_result``. The first
426+
in-process flow uses the retained owning handle so kernel async
427+
telemetry is finalized."""
429428
with conn.cursor() as cur:
430429
cur.execute_async("SELECT 7 AS n")
431430
cur.get_async_execution_result() # polls to terminal, fetches

tests/unit/test_kernel_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1125,7 +1125,7 @@ def test_kernel_error_during_result_set_construction_is_mapped():
11251125

11261126

11271127
# ---------------------------------------------------------------------------
1128-
# get_execution_result is re-callable via attach-by-id
1128+
# get_execution_result uses the owning handle once, then attach-by-id
11291129
# ---------------------------------------------------------------------------
11301130

11311131

0 commit comments

Comments
 (0)