Skip to content

[Rust] Test Arrow mux lifecycle - #867

Draft
danilonajkov-db wants to merge 1 commit into
danilo-najkov_data/effort/mux-streams-arrow-apifrom
danilo-najkov_data/effort/mux-streams-arrow
Draft

danilonajkov-db wants to merge 1 commit into
danilo-najkov_data/effort/mux-streams-arrow-apifrom
danilo-najkov_data/effort/mux-streams-arrow

Conversation

@danilonajkov-db

@danilonajkov-db danilonajkov-db commented Sep 22, 2026 •

Copy link
Copy Markdown
Member

What changes are proposed in this pull request?

Add nine Arrow mux integration tests covering terminal poisoning, healthy-lane waits, partial-ack suffix retrieval, retryable replay, mux-wide backpressure, capacity timeout and cancellation, interrupted close/recovery, construction cleanup, and poisoned capacity waiters. The mock Flight server can script individual connections so failures and healthy sibling lanes can be exercised independently. Timing-sensitive cases use virtual time and synchronization barriers.

This PR changes tests only. Stack base: #866.

How is this tested?

  • Complete Arrow integration suite: 113 passed, including all 11 Arrow mux tests and two standalone Arrow admission regressions.
  • Existing gRPC mux integration suite: 24 passed.
  • Full Rust make test and make lint matrices passed for the combined stack.
  • Standalone Avro multiplexing regression test passed.
  • Rust formatting and diff whitespace checks passed.
  • The final stack retains the same runtime code and tests validated by the full matrix above.

@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch 2 times, most recently from 783912e to 0a351a6 Compare September 22, 2026 13:52
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow-api branch from fbcdcbe to 846642f Compare September 23, 2026 11:08
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch from 0a351a6 to c7a4214 Compare September 23, 2026 11:08
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow-api branch from 846642f to fe46935 Compare September 23, 2026 12:52
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch from c7a4214 to 928c3ad Compare September 23, 2026 12:52
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow-api branch from fe46935 to e208838 Compare September 23, 2026 14:54
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch 2 times, most recently from 9827eb0 to 2fe2309 Compare September 23, 2026 15:18
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow-api branch 2 times, most recently from 71e31cb to 5e2aa6d Compare September 25, 2026 10:49
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch from 2fe2309 to ce2a23f Compare September 25, 2026 10:49
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow-api branch from 5e2aa6d to 7876529 Compare September 25, 2026 13:32
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch from ce2a23f to b6ad666 Compare September 25, 2026 13:32
Signed-off-by: danilo-najkov-db <danilo.najkov@databricks.com>
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow-api branch from 7876529 to 28e40c3 Compare September 25, 2026 15:58
@danilonajkov-db
danilonajkov-db force-pushed the danilo-najkov_data/effort/mux-streams-arrow branch from b6ad666 to c37ad58 Compare September 25, 2026 15:58
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant