[INFO] fetching crate oxigdal-streaming 0.1.3... [INFO] testing oxigdal-streaming-0.1.3 against master#562dee4820c458d823175268e41601d4c060588a for pr-154210-2 [INFO] extracting crate oxigdal-streaming 0.1.3 into /workspace/builds/worker-2-tc1/source [INFO] started tweaking crates.io crate oxigdal-streaming 0.1.3 [INFO] removed 0 missing tests [INFO] finished tweaking crates.io crate oxigdal-streaming 0.1.3 [INFO] tweaked toml for crates.io crate oxigdal-streaming 0.1.3 written to /workspace/builds/worker-2-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate oxigdal-streaming 0.1.3 on toolchain 562dee4820c458d823175268e41601d4c060588a [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate oxigdal-streaming 0.1.3 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded arrow-cast v58.0.0 [INFO] [stderr] Downloaded arrow-ord v58.0.0 [INFO] [stderr] Downloaded arrow-arith v58.0.0 [INFO] [stderr] Downloaded arrow v58.0.0 [INFO] [stderr] Downloaded arrow-select v58.0.0 [INFO] [stderr] Downloaded rocksdb v0.24.0 [INFO] [stderr] Downloaded arrow-row v58.0.0 [INFO] [stderr] Downloaded arrow-string v58.0.0 [INFO] [stderr] Downloaded libz-sys v1.1.25 [INFO] [stderr] Downloaded librocksdb-sys v0.17.3+10.4.2 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] bbb01423e7c06604311329ef85150ff0d39d05f0c63d1c73b0bbd90fe9aebcf1 [INFO] running `Command { std: "docker" "start" "-a" "bbb01423e7c06604311329ef85150ff0d39d05f0c63d1c73b0bbd90fe9aebcf1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "bbb01423e7c06604311329ef85150ff0d39d05f0c63d1c73b0bbd90fe9aebcf1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "bbb01423e7c06604311329ef85150ff0d39d05f0c63d1c73b0bbd90fe9aebcf1", kill_on_drop: false }` [INFO] [stdout] bbb01423e7c06604311329ef85150ff0d39d05f0c63d1c73b0bbd90fe9aebcf1 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] e185c302fa728aed4435870c50d9eb98ec55a032a35a8632624cd8f180f6576b [INFO] running `Command { std: "docker" "start" "-a" "e185c302fa728aed4435870c50d9eb98ec55a032a35a8632624cd8f180f6576b", kill_on_drop: false }` [INFO] [stderr] Compiling libc v0.2.183 [INFO] [stderr] Compiling libm v0.2.16 [INFO] [stderr] Compiling zerocopy v0.8.47 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling ahash v0.8.12 [INFO] [stderr] Compiling arrow-schema v58.0.0 [INFO] [stderr] Compiling lexical-util v1.0.7 [INFO] [stderr] Compiling aho-corasick v1.1.4 [INFO] [stderr] Compiling syn v2.0.117 [INFO] [stderr] Compiling regex-syntax v0.8.10 [INFO] [stderr] Compiling slab v0.4.12 [INFO] [stderr] Compiling thiserror v2.0.18 [INFO] [stderr] Compiling crossbeam-deque v0.8.6 [INFO] [stderr] Compiling crossbeam-channel v0.5.15 [INFO] [stderr] Compiling crossbeam-queue v0.3.12 [INFO] [stderr] Compiling serde_json v1.0.149 [INFO] [stderr] Compiling tracing-core v0.1.36 [INFO] [stderr] Compiling hashbrown v0.14.5 [INFO] [stderr] Compiling bytemuck v1.25.0 [INFO] [stderr] Compiling lexical-write-integer v1.0.6 [INFO] [stderr] Compiling lexical-parse-integer v1.0.6 [INFO] [stderr] Compiling lexical-parse-float v1.0.6 [INFO] [stderr] Compiling crossbeam v0.8.4 [INFO] [stderr] Compiling lexical-write-float v1.0.6 [INFO] [stderr] Compiling lexical-core v1.0.6 [INFO] [stderr] Compiling getrandom v0.3.4 [INFO] [stderr] Compiling parking_lot_core v0.9.12 [INFO] [stderr] Compiling errno v0.3.14 [INFO] [stderr] Compiling mio v1.1.1 [INFO] [stderr] Compiling socket2 v0.6.3 [INFO] [stderr] Compiling parking_lot v0.12.5 [INFO] [stderr] Compiling dashmap v6.1.0 [INFO] [stderr] Compiling signal-hook-registry v1.4.8 [INFO] [stderr] Compiling num-integer v0.1.46 [INFO] [stderr] Compiling num-complex v0.4.6 [INFO] [stderr] Compiling atoi v2.0.0 [INFO] [stderr] Compiling num-bigint v0.4.6 [INFO] [stderr] Compiling regex-automata v0.4.14 [INFO] [stderr] Compiling serde_derive v1.0.228 [INFO] [stderr] Compiling zerocopy-derive v0.8.47 [INFO] [stderr] Compiling futures-macro v0.3.32 [INFO] [stderr] Compiling thiserror-impl v2.0.18 [INFO] [stderr] Compiling tracing-attributes v0.1.31 [INFO] [stderr] Compiling oxicode_derive v0.2.1 [INFO] [stderr] Compiling tokio-macros v2.6.1 [INFO] [stderr] Compiling async-trait v0.1.89 [INFO] [stderr] Compiling futures-util v0.3.32 [INFO] [stderr] Compiling tracing v0.1.44 [INFO] [stderr] Compiling oxicode v0.2.1 [INFO] [stderr] Compiling regex v1.12.3 [INFO] [stderr] Compiling serde v1.0.228 [INFO] [stderr] Compiling bytes v1.11.1 [INFO] [stderr] Compiling chrono v0.4.44 [INFO] [stderr] Compiling oxigdal-core v0.1.3 [INFO] [stderr] Compiling futures-executor v0.3.32 [INFO] [stderr] Compiling futures v0.3.32 [INFO] [stderr] Compiling tokio v1.50.0 [INFO] [stderr] Compiling half v2.7.1 [INFO] [stderr] Compiling arrow-buffer v58.0.0 [INFO] [stderr] Compiling arrow-data v58.0.0 [INFO] [stderr] Compiling arrow-array v58.0.0 [INFO] [stderr] Compiling arrow-select v58.0.0 [INFO] [stderr] Compiling arrow-arith v58.0.0 [INFO] [stderr] Compiling arrow-row v58.0.0 [INFO] [stderr] Compiling arrow-ord v58.0.0 [INFO] [stderr] Compiling arrow-string v58.0.0 [INFO] [stderr] Compiling arrow-cast v58.0.0 [INFO] [stderr] Compiling arrow v58.0.0 [INFO] [stderr] Compiling oxigdal-streaming v0.1.3 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 01s [INFO] running `Command { std: "docker" "inspect" "e185c302fa728aed4435870c50d9eb98ec55a032a35a8632624cd8f180f6576b", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "e185c302fa728aed4435870c50d9eb98ec55a032a35a8632624cd8f180f6576b", kill_on_drop: false }` [INFO] [stdout] e185c302fa728aed4435870c50d9eb98ec55a032a35a8632624cd8f180f6576b [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 938518682ffcc9c90f1395e1f777c85fcf089f95422746713e5612967fe225ba [INFO] running `Command { std: "docker" "start" "-a" "938518682ffcc9c90f1395e1f777c85fcf089f95422746713e5612967fe225ba", kill_on_drop: false }` [INFO] [stderr] Compiling regex-automata v0.4.14 [INFO] [stderr] Compiling getrandom v0.3.4 [INFO] [stderr] Compiling cc v1.2.57 [INFO] [stderr] Compiling getrandom v0.4.2 [INFO] [stderr] Compiling anstyle v1.0.14 [INFO] [stderr] Compiling clap_lex v1.1.0 [INFO] [stderr] Compiling ciborium-io v0.2.2 [INFO] [stderr] Compiling crossbeam v0.8.4 [INFO] [stderr] Compiling tracing v0.1.44 [INFO] [stderr] Compiling itertools v0.13.0 [INFO] [stderr] Compiling ppv-lite86 v0.2.21 [INFO] [stderr] Compiling wait-timeout v0.2.1 [INFO] [stderr] Compiling tracing-log v0.2.0 [INFO] [stderr] Compiling plotters v0.3.7 [INFO] [stderr] Compiling rayon v1.11.0 [INFO] [stderr] Compiling tinytemplate v1.2.1 [INFO] [stderr] Compiling oxigdal-core v0.1.3 [INFO] [stderr] Compiling ahash v0.8.12 [INFO] [stderr] Compiling rand_core v0.9.5 [INFO] [stderr] Compiling arrow-array v58.0.0 [INFO] [stderr] Compiling clap_builder v4.6.0 [INFO] [stderr] Compiling tempfile v3.27.0 [INFO] [stderr] Compiling ciborium-ll v0.2.2 [INFO] [stderr] Compiling rand_xorshift v0.4.0 [INFO] [stderr] Compiling rand v0.9.2 [INFO] [stderr] Compiling page_size v0.6.0 [INFO] [stderr] Compiling anes v0.1.6 [INFO] [stderr] Compiling ciborium v0.2.2 [INFO] [stderr] Compiling approx v0.5.1 [INFO] [stderr] Compiling rusty-fork v0.3.1 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling alloca v0.4.0 [INFO] [stderr] Compiling proptest v1.10.0 [INFO] [stderr] Compiling criterion-plot v0.8.2 [INFO] [stderr] Compiling arrow-select v58.0.0 [INFO] [stderr] Compiling arrow-row v58.0.0 [INFO] [stderr] Compiling arrow-arith v58.0.0 [INFO] [stderr] Compiling clap v4.6.0 [INFO] [stderr] Compiling regex v1.12.3 [INFO] [stderr] Compiling matchers v0.2.0 [INFO] [stderr] Compiling tracing-subscriber v0.3.23 [INFO] [stderr] Compiling criterion v0.8.2 [INFO] [stderr] Compiling arrow-ord v58.0.0 [INFO] [stderr] Compiling arrow-string v58.0.0 [INFO] [stderr] Compiling arrow-cast v58.0.0 [INFO] [stderr] Compiling arrow v58.0.0 [INFO] [stderr] Compiling oxigdal-streaming v0.1.3 (/opt/rustwide/workdir) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 53.42s [INFO] running `Command { std: "docker" "inspect" "938518682ffcc9c90f1395e1f777c85fcf089f95422746713e5612967fe225ba", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "938518682ffcc9c90f1395e1f777c85fcf089f95422746713e5612967fe225ba", kill_on_drop: false }` [INFO] [stdout] 938518682ffcc9c90f1395e1f777c85fcf089f95422746713e5612967fe225ba [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+562dee4820c458d823175268e41601d4c060588a" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 0e1906eb58301f5578dba213c69030fffde8ad13186216397c1c0e5fa0088ba1 [INFO] running `Command { std: "docker" "start" "-a" "0e1906eb58301f5578dba213c69030fffde8ad13186216397c1c0e5fa0088ba1", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.29s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/oxigdal_streaming-92bb68a67c3e2198) [INFO] [stdout] [INFO] [stdout] running 148 tests [INFO] [stdout] test core::backpressure::tests::test_backpressure_application ... ok [INFO] [stdout] test core::flow_control::tests::test_flow_controller_creation ... ok [INFO] [stdout] test core::flow_control::tests::test_latency_recording ... ok [INFO] [stdout] test core::operators::tests::test_filter_operator ... ok [INFO] [stdout] test core::operators::tests::test_flat_map_operator ... ok [INFO] [stdout] test core::backpressure::tests::test_adaptive_capacity_adjustment ... ok [INFO] [stdout] test core::backpressure::tests::test_backpressure_manager_creation ... ok [INFO] [stdout] test core::backpressure::tests::test_buffer_utilization ... ok [INFO] [stdout] test core::operators::tests::test_map_operator ... ok [INFO] [stdout] test core::recovery::tests::test_failure_history ... ok [INFO] [stdout] test core::recovery::tests::test_success_rate ... ok [INFO] [stdout] test core::flow_control::tests::test_flow_controller_acquire ... ok [INFO] [stdout] test core::stream::tests::test_stream_element_creation ... ok [INFO] [stdout] test metrics::collector::tests::test_gauge_metric ... ok [INFO] [stdout] test core::operators::tests::test_logging_sink ... ok [INFO] [stdout] test core::recovery::tests::test_exponential_backoff ... ok [INFO] [stdout] test core::recovery::tests::test_recovery_manager_success ... ok [INFO] [stdout] test metrics::collector::tests::test_histogram_metric ... ok [INFO] [stdout] test metrics::collector::tests::test_counter_metric ... ok [INFO] [stdout] test core::stream::tests::test_stream_send_recv ... ok [INFO] [stdout] test metrics::collector::tests::test_enable_disable ... ok [INFO] [stdout] test metrics::reporter::tests::test_console_reporter ... ok [INFO] [stdout] test core::stream::tests::test_stream_close ... ok [INFO] [stdout] test metrics::collector::tests::test_metrics_collector ... ok [INFO] [stdout] test core::stream::tests::test_stream_watermark ... ok [INFO] [stdout] test metrics::reporter::tests::test_format_human ... ok [INFO] [stdout] test metrics::reporter::tests::test_format_prometheus ... ok [INFO] [stdout] test metrics::reporter::tests::test_json_reporter ... ok [INFO] [stdout] test metrics::tracker::tests::test_latency_percentiles ... ok [INFO] [stdout] test metrics::tracker::tests::test_latency_tracker ... ok [INFO] [stdout] test state::checkpoint::tests::test_checkpoint_barrier ... ok [INFO] [stdout] test state::backend::tests::test_memory_backend_snapshot ... ok [INFO] [stdout] test state::checkpoint::tests::test_checkpoint_creation ... ok [INFO] [stdout] test state::keyed_state::tests::test_list_state ... ok [INFO] [stdout] test state::checkpoint::tests::test_checkpoint_coordinator ... ok [INFO] [stdout] test state::backend::tests::test_memory_backend ... ok [INFO] [stdout] test state::operator_state::tests::test_broadcast_state ... ok [INFO] [stdout] test state::checkpoint::tests::test_checkpoint_min_pause ... ok [INFO] [stdout] test state::operator_state::tests::test_broadcast_state_snapshot ... ok [INFO] [stdout] test state::keyed_state::tests::test_map_state ... ok [INFO] [stdout] test state::keyed_state::tests::test_value_state ... ok [INFO] [stdout] test state::keyed_state::tests::test_reducing_state ... ok [INFO] [stdout] test state::checkpoint::tests::test_clear_old_checkpoints ... ok [INFO] [stdout] test state::operator_state::tests::test_union_list_state ... ok [INFO] [stdout] test state::operator_state::tests::test_union_list_state_snapshot ... ok [INFO] [stdout] test transformations::aggregate::tests::test_avg_aggregate ... ok [INFO] [stdout] test transformations::aggregate::tests::test_min_aggregate ... ok [INFO] [stdout] test transformations::aggregate::tests::test_max_aggregate ... ok [INFO] [stdout] test transformations::join::tests::test_interval_join ... ok [INFO] [stdout] test transformations::join::tests::test_join_operator ... ok [INFO] [stdout] test transformations::partition::tests::test_hash_partitioner ... ok [INFO] [stdout] test transformations::partition::tests::test_broadcast_partitioner ... ok [INFO] [stdout] test transformations::partition::tests::test_range_partitioner ... ok [INFO] [stdout] test transformations::join::tests::test_cogroup_operator ... ok [INFO] [stdout] test transformations::partition::tests::test_round_robin_partitioner ... ok [INFO] [stdout] test transformations::aggregate::tests::test_sum_aggregate ... ok [INFO] [stdout] test transformations::aggregate::tests::test_count_aggregate ... ok [INFO] [stdout] test transformations::reduce::tests::test_scan_operator ... ok [INFO] [stdout] test transformations::transform::tests::test_flatmap_transform ... ok [INFO] [stdout] test transformations::reduce::tests::test_fold_operator ... ok [INFO] [stdout] test transformations::transform::tests::test_map_transform ... ok [INFO] [stdout] test transformations::reduce::tests::test_reduce_operator ... ok [INFO] [stdout] test v2::backpressure::tests::test_consumer_consume_increments_count ... ok [INFO] [stdout] test v2::backpressure::tests::test_consumer_consume_releases_credits ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_clone_shares_state ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_release_replenishes ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_try_acquire_success ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_utilization_one_when_empty ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_utilization_zero_when_full ... ok [INFO] [stdout] test v2::backpressure::tests::test_producer_backpressure_when_no_credits ... ok [INFO] [stdout] test v2::backpressure::tests::test_producer_emit_success ... ok [INFO] [stdout] test core::flow_control::tests::test_rate_limiting ... ok [INFO] [stdout] test transformations::transform::tests::test_keyby_transform ... ok [INFO] [stdout] test v2::checkpoint::tests::test_deserialize_empty_slice_returns_error ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_try_acquire_fail_insufficient ... ok [INFO] [stdout] test transformations::partition::tests::test_hash_partitioner_consistency ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_initial_credits ... ok [INFO] [stdout] test v2::backpressure::tests::test_credit_pool_over_release_clamped_to_capacity ... ok [INFO] [stdout] test v2::checkpoint::tests::test_deserialize_truncated_data_returns_error ... ok [INFO] [stdout] test v2::checkpoint::tests::test_manager_recover_returns_last_sequence ... ok [INFO] [stdout] test transformations::reduce::tests::test_reduce_with_keys ... ok [INFO] [stdout] test v2::checkpoint::tests::test_manager_triggers_checkpoint_at_interval ... ok [INFO] [stdout] test transformations::transform::tests::test_filter_transform ... ok [INFO] [stdout] test v2::backpressure::tests::test_producer_drain_yields_pending_items ... ok [INFO] [stdout] test v2::checkpoint::tests::test_manager_total_checkpoints_counter ... ok [INFO] [stdout] test v2::checkpoint::tests::test_serialize_deserialize_with_operator_states ... ok [INFO] [stdout] test v2::checkpoint::tests::test_store_delete_before ... ok [INFO] [stdout] test v2::checkpoint::tests::test_store_latest_none_when_empty ... ok [INFO] [stdout] test v2::checkpoint::tests::test_store_multiple_streams_independent ... ok [INFO] [stdout] test v2::checkpoint::tests::test_store_save_and_latest ... ok [INFO] [stdout] test v2::checkpoint::tests::test_serialize_deserialize_round_trip_empty ... ok [INFO] [stdout] test v2::checkpoint::tests::test_manager_recover_none_before_first_checkpoint ... ok [INFO] [stdout] test v2::checkpoint::tests::test_checkpoint_state_full_round_trip ... ok [INFO] [stdout] test v2::checkpoint::tests::test_serialize_deserialize_with_source_offsets ... ok [INFO] [stdout] test v2::checkpoint::tests::test_store_trims_to_max_per_stream ... ok [INFO] [stdout] test v2::session_window::tests::test_empty_processor_has_no_sessions ... ok [INFO] [stdout] test v2::session_window::tests::test_flush_closes_open_session ... ok [INFO] [stdout] test v2::session_window::tests::test_gap_detection_closes_session ... ok [INFO] [stdout] test v2::session_window::tests::test_max_session_duration_force_closes ... ok [INFO] [stdout] test v2::session_window::tests::test_min_events_filter_drops_small_sessions ... ok [INFO] [stdout] test v2::session_window::tests::test_pending_event_count_resets_after_flush ... ok [INFO] [stdout] test v2::session_window::tests::test_single_session_from_close_events ... ok [INFO] [stdout] test v2::session_window::tests::test_session_duration_computation ... ok [INFO] [stdout] test v2::stream_join::tests::test_add_left_then_right_same_as_right_then_left ... ok [INFO] [stdout] test v2::stream_join::tests::test_expired_right_counter ... ok [INFO] [stdout] test v2::stream_join::tests::test_buffer_eviction_when_max_exceeded ... ok [INFO] [stdout] test v2::stream_join::tests::test_inner_join_matching_key_and_time ... ok [INFO] [stdout] test v2::stream_join::tests::test_inner_join_miss_outside_tolerance ... ok [INFO] [stdout] test v2::stream_join::tests::test_interval_join_no_match_outside_interval ... ok [INFO] [stdout] test v2::session_window::tests::test_events_within_gap_stay_in_same_session ... ok [INFO] [stdout] test v2::session_window::tests::test_multiple_sessions_from_gapped_stream ... ok [INFO] [stdout] test v2::stream_join::tests::test_interval_join_matches_within_interval ... ok [INFO] [stdout] test v2::stream_join::tests::test_left_outer_mode_config ... ok [INFO] [stdout] test v2::session_window::tests::test_session_id_increments ... ok [INFO] [stdout] test v2::stream_join::tests::test_no_join_on_key_mismatch ... ok [INFO] [stdout] test v2::stream_join::tests::test_time_delta_computation_is_correct ... ok [INFO] [stdout] test v2::stream_join::tests::test_total_joined_counter ... ok [INFO] [stdout] test windowing::session::tests::test_clear_expired ... ok [INFO] [stdout] test metrics::tracker::tests::test_performance_tracker ... ok [INFO] [stdout] test windowing::session::tests::test_session_assigner ... ok [INFO] [stdout] test windowing::session::tests::test_session_window ... ok [INFO] [stdout] test windowing::session::tests::test_session_window_merge ... ok [INFO] [stdout] test windowing::session::tests::test_session_window_max_duration ... ok [INFO] [stdout] test v2::stream_join::tests::test_multiple_right_events_match_single_left ... ok [INFO] [stdout] test v2::stream_join::tests::test_no_cross_key_contamination ... ok [INFO] [stdout] test windowing::session::tests::test_session_window_separate ... ok [INFO] [stdout] test windowing::sliding::tests::test_sliding_assigner ... ok [INFO] [stdout] test windowing::sliding::tests::test_sliding_window ... ok [INFO] [stdout] test windowing::sliding::tests::test_sliding_window_overlap ... ok [INFO] [stdout] test windowing::sliding::tests::test_sliding_window_with_offset ... ok [INFO] [stdout] test core::recovery::tests::test_recovery_manager_max_retries ... ok [INFO] [stdout] test windowing::tumbling::tests::test_non_overlapping_windows ... ok [INFO] [stdout] test windowing::tumbling::tests::test_tumbling_assigner ... ok [INFO] [stdout] test windowing::tumbling::tests::test_tumbling_window ... ok [INFO] [stdout] test windowing::tumbling::tests::test_tumbling_window_with_offset ... ok [INFO] [stdout] test windowing::watermark::tests::test_multi_source_watermark_manager ... ok [INFO] [stdout] test windowing::watermark::tests::test_periodic_watermark_generator ... ok [INFO] [stdout] test windowing::watermark::tests::test_remove_source_watermark ... ok [INFO] [stdout] test windowing::watermark::tests::test_watermark_creation ... ok [INFO] [stdout] test windowing::watermark::tests::test_watermark_ordering ... ok [INFO] [stdout] test windowing::window::tests::test_window_contains ... ok [INFO] [stdout] test windowing::window::tests::test_window_creation ... ok [INFO] [stdout] test windowing::window::tests::test_window_overlaps ... ok [INFO] [stdout] test windowing::window::tests::test_window_state ... ok [INFO] [stdout] test windowing::window::tests::test_window_merge ... ok [INFO] [stdout] test core::flow_control::tests::test_token_bucket ... ok [INFO] [stdout] test metrics::tracker::tests::test_throughput_tracker ... ok [INFO] [stdout] test core::recovery::tests::test_recovery_manager_retry_success ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 148 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.31s [INFO] [stdout] [INFO] [stderr] Running tests/cloud_test.rs (/opt/rustwide/target/debug/deps/cloud_test-8b1cb25968a91c38) [INFO] [stdout] [INFO] [stdout] running 72 tests [INFO] [stdout] test byte_range_http_header_basic ... ok [INFO] [stdout] test byte_range_http_header_mid_object ... ok [INFO] [stdout] test byte_range_single_byte ... ok [INFO] [stdout] test byte_range_length ... ok [INFO] [stdout] test coalescer_adjacent_ranges_merged ... ok [INFO] [stdout] test coalescer_empty_input ... ok [INFO] [stdout] test coalescer_large_gap_not_merged ... ok [INFO] [stdout] test byte_range_length_zero ... ok [INFO] [stdout] test coalescer_max_request_size_not_exceeded ... ok [INFO] [stdout] test coalescer_slice_response_middle ... ok [INFO] [stdout] test coalescer_overlapping_ranges_merged ... ok [INFO] [stdout] test coalescer_slice_response_full_range ... ok [INFO] [stdout] test coalescer_small_gap_merged ... ok [INFO] [stdout] test coalescer_sort_unsorted_input ... ok [INFO] [stdout] test coalescer_slice_response_start ... ok [INFO] [stdout] test completed_part_fields ... ok [INFO] [stdout] test hmac_sha256_empty_message ... ok [INFO] [stdout] test hmac_sha256_long_key_hashed ... ok [INFO] [stdout] test hmac_sha256_quick_brown_fox ... ok [INFO] [stdout] test hmac_sha256_rfc4231_vector1 ... ok [INFO] [stdout] test multipart_upload_add_parts ... ok [INFO] [stdout] test multipart_upload_new ... ok [INFO] [stdout] test parse_abfs_url ... ok [INFO] [stdout] test multipart_upload_to_xml_tags ... ok [INFO] [stdout] test parse_http_url ... ok [INFO] [stdout] test parse_empty_bucket_s3 ... ok [INFO] [stdout] test parse_https_url ... ok [INFO] [stdout] test parse_gs_url ... ok [INFO] [stdout] test parse_unsupported_scheme ... ok [INFO] [stdout] test parse_s3_url_no_key ... ok [INFO] [stdout] test parse_url_uppercase_scheme_normalized ... ok [INFO] [stdout] test parse_s3_url_root_key ... ok [INFO] [stdout] test parse_empty_host_https ... ok [INFO] [stdout] test multipart_upload_xml_sorted_by_part_number ... ok [INFO] [stdout] test presign_s3_contains_algorithm ... ok [INFO] [stdout] test presign_s3_missing_credentials_error ... ok [INFO] [stdout] test presign_s3_contains_signature ... ok [INFO] [stdout] test presign_s3_host_in_url ... ok [INFO] [stdout] test presigned_url_config_get ... ok [INFO] [stdout] test presign_gcs_contains_goog_algorithm ... ok [INFO] [stdout] test presign_s3_contains_date ... ok [INFO] [stdout] test parse_s3_url_basic ... ok [INFO] [stdout] test parse_az_url ... ok [INFO] [stdout] test coalescer_single_range_unchanged ... ok [INFO] [stdout] test presign_s3_contains_credential ... ok [INFO] [stdout] test presigned_url_config_put ... ok [INFO] [stdout] test retry_policy_aggressive ... ok [INFO] [stdout] test retry_policy_delay_capped_at_max ... ok [INFO] [stdout] test retry_policy_default_values ... ok [INFO] [stdout] test retry_policy_invalid_url_not_retryable ... ok [INFO] [stdout] test retry_policy_is_retryable ... ok [INFO] [stdout] test retry_policy_no_retry ... ok [INFO] [stdout] test retry_state_attempt_counter_increments ... ok [INFO] [stdout] test retry_state_initial_attempt_zero ... ok [INFO] [stdout] test retry_state_exhausts_after_max_attempts ... ok [INFO] [stdout] test retry_state_should_retry_false_non_retryable ... ok [INFO] [stdout] test retry_state_should_retry_true ... ok [INFO] [stdout] test retry_state_no_retry_exhausts_immediately ... ok [INFO] [stdout] test sha256_abc ... ok [INFO] [stdout] test sha256_empty_string ... ok [INFO] [stdout] test sha256_known_greeting ... ok [INFO] [stdout] test to_https_url_az ... ok [INFO] [stdout] test to_https_url_gs ... ok [INFO] [stdout] test to_https_url_http_upgraded ... ok [INFO] [stdout] test to_https_url_s3_default_region ... ok [INFO] [stdout] test to_https_url_s3_custom_region ... ok [INFO] [stdout] test to_https_url_with_endpoint_override ... ok [INFO] [stdout] test sha256_448_bit_message ... ok [INFO] [stdout] test parse_invalid_no_scheme ... ok [INFO] [stdout] test presign_s3_contains_expires ... ok [INFO] [stderr] Running tests/performance_test.rs (/opt/rustwide/target/debug/deps/performance_test-5fd9a1206cabef5c) [INFO] [stdout] test retry_policy_delay_increases ... ok [INFO] [stdout] test presign_gcs_starts_with_storage_googleapis ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 72 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.03s [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 46 tests [INFO] [stdout] test arrow_ipc_body_offset_computed_correctly ... ok [INFO] [stdout] test align_to_rounds_up ... ok [INFO] [stdout] test align_to_zero ... ok [INFO] [stdout] test arrow_ipc_is_arrow_file_with_magic ... ok [INFO] [stdout] test arrow_ipc_multiple_messages_round_trip ... ok [INFO] [stdout] test align_to_already_aligned ... ok [INFO] [stdout] test arrow_ipc_is_arrow_file_without_magic_returns_false ... ok [INFO] [stdout] test arrow_ipc_next_message_empty_buffer_returns_none ... ok [INFO] [stdout] test arrow_ipc_next_message_eos_marker_returns_none ... ok [INFO] [stdout] test arrow_ipc_parse_file_header_invalid_returns_error ... ok [INFO] [stdout] test arrow_ipc_parse_file_header_advances_offset ... ok [INFO] [stdout] test arrow_ipc_read_buffer_correct_slice ... ok [INFO] [stdout] test arrow_ipc_writer_default_produces_valid_magic ... ok [INFO] [stdout] test arrow_ipc_writer_round_trip_single_message ... ok [INFO] [stdout] test arrow_ipc_writer_finish_contains_magic ... ok [INFO] [stdout] test byte_range_gap_to ... ok [INFO] [stdout] test byte_range_gap_to_adjacent ... ok [INFO] [stdout] test byte_range_is_empty_false ... ok [INFO] [stdout] test byte_range_merge ... ok [INFO] [stdout] test byte_range_new_and_len ... ok [INFO] [stdout] test byte_range_overlaps_or_adjoins_adjacent ... ok [INFO] [stdout] test byte_range_is_empty_true ... ok [INFO] [stdout] test byte_range_overlaps_or_adjoins_gap ... ok [INFO] [stdout] test byte_range_overlaps_or_adjoins_overlap ... ok [INFO] [stdout] test coalesce_deduplicates_identical_ranges ... ok [INFO] [stdout] test coalesce_exceeds_max_merged_size_splits ... ok [INFO] [stdout] test coalesce_output_ranges_are_sorted ... ok [INFO] [stdout] test coalesce_large_gap_keeps_separate ... ok [INFO] [stdout] test coalesce_small_gap_merges_ranges ... ok [INFO] [stdout] test coalesced_request_extract_correct_slice ... ok [INFO] [stdout] test coalesced_request_extract_out_of_range_returns_none ... ok [INFO] [stdout] test compute_stats_overhead_ratio_zero_when_no_gaps ... ok [INFO] [stdout] test compute_stats_request_reduction ... ok [INFO] [stdout] test coalesce_single_range_returns_one_request ... ok [INFO] [stdout] test prefetch_hint_construction ... ok [INFO] [stdout] test prefetch_scheduler_add_and_count ... ok [INFO] [stdout] test prefetch_scheduler_sorted_hints_respects_priority_order ... ok [INFO] [stdout] test byte_range_overlaps_or_adjoins_same ... ok [INFO] [stdout] test coalesce_empty_list_returns_empty ... ok [INFO] [stdout] test mapped_file_open_nonexistent_returns_error ... ok [INFO] [stdout] test mapped_file_read_ranges_multiple ... ok [INFO] [stdout] test mapped_file_file_size_correct ... ok [INFO] [stdout] test mapped_file_read_range_past_end_returns_error ... ok [INFO] [stdout] test mapped_file_as_slice_returns_all_data ... ok [INFO] [stdout] test mapped_file_read_range_within_bounds ... ok [INFO] [stdout] test mapped_file_read_range_zero_length ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 46 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.04s [INFO] [stdout] [INFO] [stderr] Running tests/proptest_streaming.rs (/opt/rustwide/target/debug/deps/proptest_streaming-15029e6de413c80d) [INFO] [stdout] [INFO] [stdout] running 20 tests [INFO] [stdout] test prop_align_to_multiple_of_alignment ... ok [INFO] [stdout] test prop_align_to_idempotent ... ok [INFO] [stdout] test prop_byte_range_gap_zero_for_overlapping ... ok [INFO] [stdout] test prop_byte_range_merge_idempotent ... ok [INFO] [stdout] test prop_align_to_overhead_lt_alignment ... ok [INFO] [stdout] test prop_coalesce_covers_all_inputs ... ok [INFO] [stdout] test prop_coalesce_count_le_input ... ok [INFO] [stdout] test prop_byte_range_merge_commutative ... ok [INFO] [stdout] test prop_coalesce_empty_input ... ok [INFO] [stdout] test prop_arrow_ipc_empty_writer_is_valid ... ok [INFO] [stdout] test prop_coalesce_large_gap_single_output ... ok [INFO] [stdout] test prop_coalesce_idempotent_count ... ok [INFO] [stdout] test prop_byte_range_merge_contains_both ... ok [INFO] [stdout] test prop_align_to_result_ge_input ... ok [INFO] [stdout] test prop_byte_range_empty_iff_start_eq_end ... ok [INFO] [stdout] test prop_byte_range_len_equals_end_minus_start ... ok [INFO] [stdout] test prop_coalesce_output_non_overlapping ... ok [INFO] [stdout] test prop_byte_range_is_empty_consistent_with_len ... ok [INFO] [stdout] test prop_arrow_ipc_multiple_messages ... ok [INFO] [stdout] test prop_arrow_ipc_roundtrip_lengths ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 20 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.18s [INFO] [stdout] [INFO] [stderr] Running tests/streaming_v2_test.rs (/opt/rustwide/target/debug/deps/streaming_v2_test-77e3c2456963ee90) [INFO] [stdout] [INFO] [stdout] running 61 tests [INFO] [stdout] test bp_pool_over_release_clamped_to_capacity ... ok [INFO] [stdout] test bp_consumer_consume_releases_credits_to_pool ... ok [INFO] [stdout] test bp_invalid_credit_amount_returns_error ... ok [INFO] [stdout] test bp_full_producer_consumer_round_trip ... ok [INFO] [stdout] test bp_pool_release_replenishes_credits ... ok [INFO] [stdout] test bp_pool_try_acquire_fails_when_insufficient_credits ... ok [INFO] [stdout] test bp_producer_backpressure_when_no_credits ... ok [INFO] [stdout] test bp_pool_try_acquire_succeeds_when_credits_available ... ok [INFO] [stdout] test bp_pool_utilization_one_when_fully_consumed ... ok [INFO] [stdout] test bp_pool_utilization_zero_when_full ... ok [INFO] [stdout] test bp_producer_emit_success_consumes_credits ... ok [INFO] [stdout] test bp_producer_drain_clears_pending_queue ... ok [INFO] [stdout] test bp_pool_construction_initial_credits_correct ... ok [INFO] [stdout] test ck_delete_before_removes_old_checkpoints ... ok [INFO] [stdout] test ck_deserialize_truncated_data_returns_error ... ok [INFO] [stdout] test ck_manager_recover_returns_last_sequence ... ok [INFO] [stdout] test ck_manager_triggers_checkpoint_at_interval ... ok [INFO] [stdout] test ck_recover_returns_none_before_first_checkpoint ... ok [INFO] [stdout] test ck_store_save_and_latest ... ok [INFO] [stdout] test ck_operator_states_round_trip ... ok [INFO] [stdout] test ck_store_trims_to_max_per_stream ... ok [INFO] [stdout] test sj_add_left_then_right_vs_right_then_left_same_result ... ok [INFO] [stdout] test ck_watermark_preserved_in_checkpoint ... ok [INFO] [stdout] test ck_total_checkpoints_counter_correct ... ok [INFO] [stdout] test ck_state_serialize_deserialize_round_trip_empty ... ok [INFO] [stdout] test sj_buffer_eviction_when_max_buffer_size_exceeded ... ok [INFO] [stdout] test ck_store_latest_returns_none_for_unknown_stream ... ok [INFO] [stdout] test sj_exact_tolerance_boundary_matches ... ok [INFO] [stdout] test sj_expired_right_counter_increments_on_eviction ... ok [INFO] [stdout] test sj_drain_output_clears_queue ... ok [INFO] [stdout] test sj_inner_join_matching_key_and_time ... ok [INFO] [stdout] test sj_interval_join_no_match_below_lower ... ok [INFO] [stdout] test sj_left_outer_mode_produces_matching_pair ... ok [INFO] [stdout] test sj_multiple_right_events_match_single_left ... ok [INFO] [stdout] test sj_no_cross_key_contamination ... ok [INFO] [stdout] test sj_no_join_on_key_mismatch ... ok [INFO] [stdout] test sj_time_delta_computation_is_correct ... ok [INFO] [stdout] test sw_drain_returns_empty_vec_when_called_twice ... ok [INFO] [stdout] test sw_duration_computation_correct ... ok [INFO] [stdout] test sw_empty_processor_yields_no_sessions ... ok [INFO] [stdout] test sw_events_within_gap_stay_in_same_session ... ok [INFO] [stdout] test bp_consumer_consume_increments_count ... ok [INFO] [stdout] test sj_interval_join_matches_within_interval ... ok [INFO] [stdout] test sj_total_joined_counter_increments ... ok [INFO] [stdout] test sw_flush_closes_open_session ... ok [INFO] [stdout] test sw_min_events_filter_drops_small_sessions ... ok [INFO] [stdout] test sw_multiple_sessions_from_gapped_stream ... ok [INFO] [stdout] test sj_inner_join_miss_outside_tolerance ... ok [INFO] [stdout] test sw_session_id_increments_monotonically ... ok [INFO] [stdout] test sw_min_events_one_passes_single_event_sessions ... ok [INFO] [stdout] test ck_multiple_streams_independent ... ok [INFO] [stdout] test sw_session_is_not_empty_after_events ... ok [INFO] [stdout] test sw_total_sessions_closed_tracks_count ... ok [INFO] [stdout] test sw_gap_detection_closes_session ... ok [INFO] [stdout] test sw_single_session_from_close_events ... ok [INFO] [stdout] test ck_source_offsets_round_trip ... ok [INFO] [stdout] test ck_deserialize_empty_slice_returns_error ... ok [INFO] [stdout] test bp_pool_clone_shares_same_atomic ... ok [INFO] [stdout] test sw_max_session_duration_force_closes ... ok [INFO] [stdout] test sw_pending_count_resets_after_flush ... ok [INFO] [stdout] test sw_session_events_are_in_arrival_order ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 61 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "0e1906eb58301f5578dba213c69030fffde8ad13186216397c1c0e5fa0088ba1", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "0e1906eb58301f5578dba213c69030fffde8ad13186216397c1c0e5fa0088ba1", kill_on_drop: false }` [INFO] [stdout] 0e1906eb58301f5578dba213c69030fffde8ad13186216397c1c0e5fa0088ba1