[INFO] fetching crate queue_workers 0.5.1...
[INFO] testing queue_workers-0.5.1 against 1.99.0-beta.8 for beta-1.100-2
[INFO] extracting crate queue_workers 0.5.1 into /workspace/builds/worker-7-tc1/source
[INFO] started tweaking crates.io crate queue_workers 0.5.1
[INFO] removed 0 missing tests
[INFO] finished tweaking crates.io crate queue_workers 0.5.1
[INFO] tweaked toml for crates.io crate queue_workers 0.5.1 written to /workspace/builds/worker-7-tc1/source/Cargo.toml
[INFO] validating manifest of crates.io crate queue_workers 0.5.1 on toolchain 1.99.0-beta.8
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate queue_workers 0.5.1 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" "+1.99.0-beta.8" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded serde_derive v1.0.219
[INFO] [stderr]   Downloaded tokio-macros v2.5.0
[INFO] [stderr]   Downloaded tracing-test-macro v0.2.5
[INFO] [stderr]   Downloaded thread_local v1.1.8
[INFO] [stderr]   Downloaded num_cpus v1.16.0
[INFO] [stderr]   Downloaded write16 v1.0.0
[INFO] [stderr]   Downloaded form_urlencoded v1.2.1
[INFO] [stderr]   Downloaded idna_adapter v1.2.0
[INFO] [stderr]   Downloaded anstyle v1.0.10
[INFO] [stderr]   Downloaded unicode-ident v1.0.18
[INFO] [stderr]   Downloaded nu-ansi-term v0.46.0
[INFO] [stderr]   Downloaded uuid v1.16.0
[INFO] [stderr]   Downloaded yoke-derive v0.7.5
[INFO] [stderr]   Downloaded windows-link v0.1.1
[INFO] [stderr]   Downloaded test-log-macros v0.2.17
[INFO] [stderr]   Downloaded colorchoice v1.0.3
[INFO] [stderr]   Downloaded sha1_smol v1.0.1
[INFO] [stderr]   Downloaded hermit-abi v0.3.9
[INFO] [stderr]   Downloaded tracing-test v0.2.5
[INFO] [stderr]   Downloaded adler2 v2.0.0
[INFO] [stderr]   Downloaded async-trait v0.1.88
[INFO] [stderr]   Downloaded windows-strings v0.4.0
[INFO] [stderr]   Downloaded test-log v0.2.17
[INFO] [stderr]   Downloaded anstyle-wincon v3.0.7
[INFO] [stderr]   Downloaded anstyle-query v1.1.2
[INFO] [stderr]   Downloaded icu_provider_macros v1.5.0
[INFO] [stderr]   Downloaded wasm-bindgen-macro v0.2.100
[INFO] [stderr]   Downloaded wasm-bindgen-shared v0.2.100
[INFO] [stderr]   Downloaded env_filter v0.1.3
[INFO] [stderr]   Downloaded litemap v0.7.5
[INFO] [stderr]   Downloaded slab v0.4.9
[INFO] [stderr]   Downloaded windows-interface v0.59.1
[INFO] [stderr]   Downloaded wit-bindgen-rt v0.39.0
[INFO] [stderr]   Downloaded anstream v0.6.18
[INFO] [stderr]   Downloaded percent-encoding v2.3.1
[INFO] [stderr]   Downloaded tinystr v0.7.6
[INFO] [stderr]   Downloaded wasm-bindgen-macro-support v0.2.100
[INFO] [stderr]   Downloaded signal-hook-registry v1.4.2
[INFO] [stderr]   Downloaded autocfg v1.4.0
[INFO] [stderr]   Downloaded thiserror-impl v2.0.12
[INFO] [stderr]   Downloaded anstyle-parse v0.2.6
[INFO] [stderr]   Downloaded zerovec-derive v0.10.3
[INFO] [stderr]   Downloaded synstructure v0.13.1
[INFO] [stderr]   Downloaded writeable v0.5.5
[INFO] [stderr]   Downloaded utf16_iter v1.0.5
[INFO] [stderr]   Downloaded wasm-bindgen-backend v0.2.100
[INFO] [stderr]   Downloaded rustversion v1.0.20
[INFO] [stderr]   Downloaded cc v1.2.19
[INFO] [stderr]   Downloaded r-efi v5.2.0
[INFO] [stderr]   Downloaded log v0.4.27
[INFO] [stderr]   Downloaded tracing-attributes v0.1.28
[INFO] [stderr]   Downloaded smallvec v1.15.0
[INFO] [stderr]   Downloaded overload v0.1.1
[INFO] [stderr]   Downloaded parking_lot v0.12.3
[INFO] [stderr]   Downloaded parking_lot_core v0.9.10
[INFO] [stderr]   Downloaded redox_syscall v0.5.11
[INFO] [stderr]   Downloaded lock_api v0.4.12
[INFO] [stderr]   Downloaded wasi v0.11.0+wasi-snapshot-preview1
[INFO] [stderr]   Downloaded rustc-demangle v0.1.24
[INFO] [stderr]   Downloaded thiserror v2.0.12
[INFO] [stderr]   Downloaded env_logger v0.11.8
[INFO] [stderr]   Downloaded yoke v0.7.5
[INFO] [stderr]   Downloaded icu_locid_transform v1.5.0
[INFO] [stderr]   Downloaded icu_locid_transform_data v1.5.1
[INFO] [stderr]   Downloaded wasm-bindgen v0.2.100
[INFO] [stderr]   Downloaded iana-time-zone v0.1.63
[INFO] [stderr]   Downloaded windows-core v0.61.0
[INFO] [stderr]   Downloaded windows-result v0.3.2
[INFO] [stderr]   Downloaded windows-implement v0.60.0
[INFO] [stderr]   Downloaded android-tzdata v0.1.1
[INFO] [stderr]   Downloaded serde v1.0.219
[INFO] [stderr]   Downloaded getrandom v0.3.2
[INFO] [stderr]   Downloaded tracing-core v0.1.33
[INFO] [stderr]   Downloaded socket2 v0.5.9
[INFO] [stderr]   Downloaded miniz_oxide v0.8.5
[INFO] [stderr]   Downloaded icu_properties v1.5.1
[INFO] [stderr]   Downloaded icu_locid v1.5.0
[INFO] [stderr]   Downloaded icu_normalizer v1.5.0
[INFO] [stderr]   Downloaded icu_normalizer_data v1.5.1
[INFO] [stderr]   Downloaded js-sys v0.3.77
[INFO] [stderr]   Downloaded proc-macro2 v1.0.94
[INFO] [stderr]   Downloaded bitflags v2.9.0
[INFO] [stderr]   Downloaded backtrace v0.3.74
[INFO] [stderr]   Downloaded url v2.5.4
[INFO] [stderr]   Downloaded icu_provider v1.5.0
[INFO] [stderr]   Downloaded arc-swap v1.7.1
[INFO] [stderr]   Downloaded bumpalo v3.17.0
[INFO] [stderr]   Downloaded memchr v2.7.4
[INFO] [stderr]   Downloaded mio v1.0.3
[INFO] [stderr]   Downloaded icu_collections v1.5.0
[INFO] [stderr]   Downloaded zerovec v0.10.4
[INFO] [stderr]   Downloaded idna v1.0.3
[INFO] [stderr]   Downloaded wasi v0.14.2+wasi-0.2.4
[INFO] [stderr]   Downloaded tokio-util v0.7.14
[INFO] [stderr]   Downloaded serde_json v1.0.140
[INFO] [stderr]   Downloaded tracing-subscriber v0.3.19
[INFO] [stderr]   Downloaded icu_properties_data v1.5.1
[INFO] [stderr]   Downloaded chrono v0.4.40
[INFO] [stderr]   Downloaded regex v1.11.1
[INFO] [stderr]   Downloaded regex-syntax v0.6.29
[INFO] [stderr]   Downloaded redis v0.29.5
[INFO] [stderr]   Downloaded syn v2.0.100
[INFO] [stderr]   Downloaded regex-syntax v0.8.5
[INFO] [stderr]   Downloaded regex-automata v0.4.9
[INFO] [stderr]   Downloaded libc v0.2.171
[INFO] [stderr]   Downloaded tokio v1.44.2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,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" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:3111399a4047eeb3a02b7a90e478d715f38a8c6669b5c4b49d30a17385265909" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] 22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe
[INFO] running `Command { std: "docker" "start" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.94
[INFO] [stderr]    Compiling unicode-ident v1.0.18
[INFO] [stderr]    Compiling autocfg v1.4.0
[INFO] [stderr]    Compiling libc v0.2.171
[INFO] [stderr]    Compiling smallvec v1.15.0
[INFO] [stderr]    Compiling litemap v0.7.5
[INFO] [stderr]    Compiling icu_locid_transform_data v1.5.1
[INFO] [stderr]    Compiling writeable v0.5.5
[INFO] [stderr]    Compiling icu_properties_data v1.5.1
[INFO] [stderr]    Compiling parking_lot_core v0.9.10
[INFO] [stderr]    Compiling icu_normalizer_data v1.5.1
[INFO] [stderr]    Compiling scopeguard v1.2.0
[INFO] [stderr]    Compiling memchr v2.7.4
[INFO] [stderr]    Compiling utf16_iter v1.0.5
[INFO] [stderr]    Compiling serde v1.0.219
[INFO] [stderr]    Compiling write16 v1.0.0
[INFO] [stderr]    Compiling futures-channel v0.3.31
[INFO] [stderr]    Compiling percent-encoding v2.3.1
[INFO] [stderr]    Compiling getrandom v0.3.2
[INFO] [stderr]    Compiling serde_json v1.0.140
[INFO] [stderr]    Compiling form_urlencoded v1.2.1
[INFO] [stderr]    Compiling thiserror v2.0.12
[INFO] [stderr]    Compiling arc-swap v1.7.1
[INFO] [stderr]    Compiling iana-time-zone v0.1.63
[INFO] [stderr]    Compiling sha1_smol v1.0.1
[INFO] [stderr]    Compiling log v0.4.27
[INFO] [stderr]    Compiling lock_api v0.4.12
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]    Compiling slab v0.4.9
[INFO] [stderr]    Compiling quote v1.0.40
[INFO] [stderr]    Compiling syn v2.0.100
[INFO] [stderr]    Compiling mio v1.0.3
[INFO] [stderr]    Compiling socket2 v0.5.9
[INFO] [stderr]    Compiling signal-hook-registry v1.4.2
[INFO] [stderr]    Compiling num_cpus v1.16.0
[INFO] [stderr]    Compiling parking_lot v0.12.3
[INFO] [stderr]    Compiling num-integer v0.1.46
[INFO] [stderr]    Compiling num-bigint v0.4.6
[INFO] [stderr]    Compiling synstructure v0.13.1
[INFO] [stderr]    Compiling zerovec-derive v0.10.3
[INFO] [stderr]    Compiling displaydoc v0.2.5
[INFO] [stderr]    Compiling icu_provider_macros v1.5.0
[INFO] [stderr]    Compiling tokio-macros v2.5.0
[INFO] [stderr]    Compiling serde_derive v1.0.219
[INFO] [stderr]    Compiling futures-macro v0.3.31
[INFO] [stderr]    Compiling thiserror-impl v2.0.12
[INFO] [stderr]    Compiling async-trait v0.1.88
[INFO] [stderr]    Compiling zerofrom-derive v0.1.6
[INFO] [stderr]    Compiling yoke-derive v0.7.5
[INFO] [stderr]    Compiling tokio v1.44.2
[INFO] [stderr]    Compiling futures-util v0.3.31
[INFO] [stderr]    Compiling zerofrom v0.1.6
[INFO] [stderr]    Compiling yoke v0.7.5
[INFO] [stderr]    Compiling zerovec v0.10.4
[INFO] [stderr]    Compiling tinystr v0.7.6
[INFO] [stderr]    Compiling icu_collections v1.5.0
[INFO] [stderr]    Compiling icu_locid v1.5.0
[INFO] [stderr]    Compiling icu_provider v1.5.0
[INFO] [stderr]    Compiling icu_locid_transform v1.5.0
[INFO] [stderr]    Compiling futures-executor v0.3.31
[INFO] [stderr]    Compiling futures v0.3.31
[INFO] [stderr]    Compiling icu_properties v1.5.1
[INFO] [stderr]    Compiling uuid v1.16.0
[INFO] [stderr]    Compiling chrono v0.4.40
[INFO] [stderr]    Compiling tokio-util v0.7.14
[INFO] [stderr]    Compiling icu_normalizer v1.5.0
[INFO] [stderr]    Compiling combine v4.6.7
[INFO] [stderr]    Compiling idna_adapter v1.2.0
[INFO] [stderr]    Compiling idna v1.0.3
[INFO] [stderr]    Compiling url v2.5.4
[INFO] [stderr]    Compiling redis v0.29.5
[INFO] [stderr]    Compiling queue_workers v0.5.1 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 51.58s
[INFO] running `Command { std: "docker" "inspect" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling log v0.4.27
[INFO] [stderr]    Compiling tracing-core v0.1.33
[INFO] [stderr]    Compiling utf8parse v0.2.2
[INFO] [stderr]    Compiling regex-syntax v0.6.29
[INFO] [stderr]    Compiling regex-syntax v0.8.5
[INFO] [stderr]    Compiling tracing-attributes v0.1.28
[INFO] [stderr]    Compiling anstyle v1.0.10
[INFO] [stderr]    Compiling is_terminal_polyfill v1.70.1
[INFO] [stderr]    Compiling colorchoice v1.0.3
[INFO] [stderr]    Compiling anstyle-query v1.1.2
[INFO] [stderr]    Compiling overload v0.1.1
[INFO] [stderr]    Compiling sharded-slab v0.1.7
[INFO] [stderr]    Compiling thread_local v1.1.8
[INFO] [stderr]    Compiling tracing-test-macro v0.2.5
[INFO] [stderr]    Compiling test-log-macros v0.2.17
[INFO] [stderr]    Compiling nu-ansi-term v0.46.0
[INFO] [stderr]    Compiling anstyle-parse v0.2.6
[INFO] [stderr]    Compiling anstream v0.6.18
[INFO] [stderr]    Compiling env_filter v0.1.3
[INFO] [stderr]    Compiling queue_workers v0.5.1 (/opt/rustwide/workdir)
[INFO] [stderr]    Compiling tracing-log v0.2.0
[INFO] [stderr]    Compiling tracing-serde v0.2.0
[INFO] [stderr]    Compiling env_logger v0.11.8
[INFO] [stderr]    Compiling test-log v0.2.17
[INFO] [stderr]    Compiling tracing v0.1.41
[INFO] [stderr]    Compiling regex-automata v0.4.9
[INFO] [stderr]    Compiling regex-automata v0.1.10
[INFO] [stderr]    Compiling matchers v0.1.0
[INFO] [stderr]    Compiling regex v1.11.1
[INFO] [stderr]    Compiling tracing-subscriber v0.3.19
[INFO] [stderr]    Compiling tracing-test v0.2.5
[INFO] [stdout] warning: struct `TestQueue` is never constructed
[INFO] [stdout]    --> tests/common/mod.rs:254:12
[INFO] [stdout]     |
[INFO] [stdout] 254 | pub struct TestQueue {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `TestQueue` is never constructed
[INFO] [stdout]    --> tests/common/mod.rs:254:12
[INFO] [stdout]     |
[INFO] [stdout] 254 | pub struct TestQueue {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 24.95s
[INFO] running `Command { std: "docker" "inspect" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen", kill_on_drop: false }`
[INFO] [stderr] warning: struct `TestQueue` is never constructed
[INFO] [stderr]    --> tests/common/mod.rs:254:12
[INFO] [stderr]     |
[INFO] [stderr] 254 | pub struct TestQueue {
[INFO] [stderr]     |            ^^^^^^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: `queue_workers` (test "serial_worker_integration") generated 1 warning
[INFO] [stderr] warning: `queue_workers` (test "concurrent_worker_integration") generated 1 warning (1 duplicate)
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.13s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/queue_workers-5901793ba2d16b6b)
[INFO] [stdout] 
[INFO] [stdout] running 4 tests
[INFO] [stderr]      Running tests/concurrent_worker.rs (/opt/rustwide/target/debug/deps/concurrent_worker-f0ed07dce300f1a9)
[INFO] [stdout] test job::tests::test_clone ... ok
[INFO] [stdout] test job::tests::test_serialization ... ok
[INFO] [stdout] test job::tests::test_update_status ... ok
[INFO] [stdout] test job::tests::test_new_job_metadata ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 20 tests
[INFO] [stdout] test test_concurrent_worker_job_retries_once ... ok
[INFO] [stdout] test test_concurrent_worker_job_respects_worker_config_retry_limit ... ok
[INFO] [stdout] test test_concurrent_worker_job_retries_until_it_fails ... ok
[INFO] [stdout] test common::tests::test_span_logging ... ok
[INFO] [stdout] test common::tests::test_logging_levels ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.069737Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_graceful_shutdown_completes_job","threadId":"ThreadId(6)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.069828Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_graceful_shutdown_completes_job","threadId":"ThreadId(6)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.074224Z","level":"INFO","fields":{"message":"Starting concurrent worker...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":96},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":96,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.074346Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.074395Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.074460Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.074495Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.075668Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.075761Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.075803Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.075850Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.075930Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.075978Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.076052Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.076098Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.076150Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.076192Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.076247Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.076290Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098314Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098427Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098492Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098545Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098587Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098646Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098702Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098741Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098792Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098830Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098915Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.098960Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.100122Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 600ms for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_graceful_shutdown_completes_job","threadId":"ThreadId(6)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.104907Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105029Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105085Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105118Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105153Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105197Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105228Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105264Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105294Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105736Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105806Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.105848Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.106820Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 1s for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_job_retries_twice","threadId":"ThreadId(10)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.111979Z","level":"INFO","fields":{"message":"Shutdown timeout reached, forcing shutdown...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":117},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":117,"threadName":"test_concurrent_worker_graceful_shutdown_cancels_ongoing_job","threadId":"ThreadId(5)"}
[INFO] [stdout] test test_concurrent_worker_graceful_shutdown_cancels_ongoing_job ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.116544Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 100ms for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_shutdown_during_job_retry_delay","threadId":"ThreadId(18)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120280Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120366Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120426Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120474Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120511Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120553Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120625Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120672Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120728Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120771Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120824Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.120862Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.129038Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.129140Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.129179Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143046Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143164Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143216Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143257Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143296Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143343Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143402Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143449Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143501Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143541Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143587Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.143641Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.155090Z","level":"INFO","fields":{"message":"Shutdown timeout reached, forcing shutdown...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":117},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":117,"threadName":"test_concurrent_worker_leaves_jobs_in_queue_on_shutdown","threadId":"ThreadId(13)"}
[INFO] [stdout] test test_concurrent_worker_leaves_jobs_in_queue_on_shutdown ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158001Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158104Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158154Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158195Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158235Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158287Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158332Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158381Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.158425Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.159988Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_job_retries_twice","threadId":"ThreadId(10)"}
[INFO] [stdout] test test_concurrent_worker_job_retries_twice ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.164924Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.165053Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.167339Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.166894Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_shutdown_signal_channel_closed","threadId":"ThreadId(19)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.167678Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.167734Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.167788Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.167840Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.167917Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] test test_concurrent_worker_shutdown_signal_channel_closed ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.168399Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 500ms for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_shutdown_with_empty_queue","threadId":"ThreadId(20)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.175611Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.175721Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.175769Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.183037Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.183133Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.186346Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.186421Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209564Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209665Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209708Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209756Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209795Z","level":"DEBUG","fields":{"message":"Picked up new job from queue","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":59},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":59,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209841Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.209924Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.218011Z","level":"INFO","fields":{"message":"Shutdown timeout reached, forcing shutdown...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":117},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":117,"threadName":"test_concurrent_worker_shutdown_during_job_retry_delay","threadId":"ThreadId(18)"}
[INFO] [stdout] test test_concurrent_worker_shutdown_during_job_retry_delay ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.253525Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 1s for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_job_execution_order","threadId":"ThreadId(7)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.255855Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 1s for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_queue_errors","threadId":"ThreadId(16)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.263145Z","level":"INFO","fields":{"message":"Job executed successfully","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":132},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":132,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.263249Z","level":"DEBUG","fields":{"message":"Processing new job","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":56},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":56,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.355255Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 1s for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.356221Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 1s for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.375994Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 1s for running jobs to complete...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":105},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":105,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.552276Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_job_execution_order","threadId":"ThreadId(7)"}
[INFO] [stdout] test test_concurrent_worker_job_execution_order ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.552782Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_completes_job_during_shutdown","threadId":"ThreadId(4)"}
[INFO] [stdout] test test_concurrent_worker_completes_job_during_shutdown ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.556224Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_multiple_jobs","threadId":"ThreadId(14)"}
[INFO] [stdout] test test_concurrent_worker_multiple_jobs ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.557072Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_queue_errors","threadId":"ThreadId(16)"}
[INFO] [stdout] test test_concurrent_worker_queue_errors ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.563107Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_job_succeeds_without_retries","threadId":"ThreadId(12)"}
[INFO] [stdout] test test_concurrent_worker_job_succeeds_without_retries ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.569207Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_shutdown_with_empty_queue","threadId":"ThreadId(20)"}
[INFO] [stdout] test test_concurrent_worker_shutdown_with_empty_queue ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.570967Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_graceful_shutdown_completes_job","threadId":"ThreadId(6)"}
[INFO] [stdout] test test_concurrent_worker_graceful_shutdown_completes_job ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.669057Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_respects_concurrency_limit","threadId":"ThreadId(17)"}
[INFO] [stdout] test test_concurrent_worker_respects_concurrency_limit ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.688025Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_varying_job_durations","threadId":"ThreadId(21)"}
[INFO] [stdout] test test_concurrent_worker_varying_job_durations ... ok
[INFO] [stdout] {"timestamp":"2026-10-06T16:59:35.764508Z","level":"INFO","fields":{"message":"All jobs completed, shutting down...","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":122},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":122,"threadName":"test_concurrent_worker_parallel_execution","threadId":"ThreadId(15)"}
[INFO] [stderr]      Running tests/concurrent_worker_integration.rs (/opt/rustwide/target/debug/deps/concurrent_worker_integration-f9dc4f60ccea248b)
[INFO] [stdout] test test_concurrent_worker_parallel_execution ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 20 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.72s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 5 tests
[INFO] [stdout] test common::tests::test_logging_levels ... ok
[INFO] [stdout] test common::tests::test_span_logging ... ok
[INFO] [stdout] test test_concurrent_workers ... FAILED
[INFO] [stdout] test test_queue_persistence ... FAILED
[INFO] [stdout] test test_complete_workflow ... FAILED
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- test_concurrent_workers stdout ----
[INFO] [stdout] 
[INFO] [stdout] thread 'test_concurrent_workers' (2032) panicked at tests/concurrent_worker_integration.rs:226:31:
[INFO] [stdout] Failed to push job: ConnectionError("Connection refused (os error 111)")
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0:     0x61f390b6f591 - std[70759c8f55707aa4]::backtrace_rs::backtrace::libunwind::trace
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9
[INFO] [stdout]    1:     0x61f390b6f591 - std[70759c8f55707aa4]::backtrace_rs::backtrace::trace_unsynchronized::<std[70759c8f55707aa4]::sys::backtrace::_print_fmt::{closure#1}>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14
[INFO] [stdout]    2:     0x61f390b6f591 - std[70759c8f55707aa4]::sys::backtrace::_print_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:74:9
[INFO] [stdout]    3:     0x61f390b6f591 - <<std[70759c8f55707aa4]::sys::backtrace::BacktraceLock>::print::DisplayBacktrace as core[df12db4294e9bfd3]::fmt::Display>::fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:44:26
[INFO] [stdout]    4:     0x61f390b8698a - <core[df12db4294e9bfd3]::fmt::rt::Argument>::fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/fmt/rt.rs:152:76
[INFO] [stdout]    5:     0x61f390b8698a - core[df12db4294e9bfd3]::fmt::write
[INFO] [stdout]    6:     0x61f390b740ac - core[df12db4294e9bfd3]::io::write::default_write_fmt::<alloc[2182bb758b4b3781]::vec::Vec<u8>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/io/write.rs:402:11
[INFO] [stdout]    7:     0x61f390b740ac - <alloc[2182bb758b4b3781]::vec::Vec<u8> as core[df12db4294e9bfd3]::io::write::Write>::write_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/io/write.rs:335:13
[INFO] [stdout]    8:     0x61f390b4ab96 - <std[70759c8f55707aa4]::sys::backtrace::BacktraceLock>::print
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:47:9
[INFO] [stdout]    9:     0x61f390b4ab96 - std[70759c8f55707aa4]::panicking::default_hook::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:292:27
[INFO] [stdout]   10:     0x61f390b674b9 - std[70759c8f55707aa4]::panicking::default_hook
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:316:9
[INFO] [stdout]   11:     0x61f3907088f0 - <alloc[2182bb758b4b3781]::boxed::Box<dyn for<'a, 'b> core[df12db4294e9bfd3]::ops::function::Fn<(&'a std[70759c8f55707aa4]::panic::PanicHookInfo<'b>,), Output = ()> + core[df12db4294e9bfd3]::marker::Send + core[df12db4294e9bfd3]::marker::Sync> as core[df12db4294e9bfd3]::ops::function::Fn<(&std[70759c8f55707aa4]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2334:9
[INFO] [stdout]   12:     0x61f3907088f0 - test[9d35eded1c95d3be]::test_main_inner::<test[9d35eded1c95d3be]::test_main_static::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:155:21
[INFO] [stdout]   13:     0x61f390b677e2 - <alloc[2182bb758b4b3781]::boxed::Box<dyn for<'a, 'b> core[df12db4294e9bfd3]::ops::function::Fn<(&'a std[70759c8f55707aa4]::panic::PanicHookInfo<'b>,), Output = ()> + core[df12db4294e9bfd3]::marker::Send + core[df12db4294e9bfd3]::marker::Sync> as core[df12db4294e9bfd3]::ops::function::Fn<(&std[70759c8f55707aa4]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2334:9
[INFO] [stdout]   14:     0x61f390b677e2 - std[70759c8f55707aa4]::panicking::panic_with_hook
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:823:13
[INFO] [stdout]   15:     0x61f390b4ac42 - std[70759c8f55707aa4]::panicking::panic_handler::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:688:13
[INFO] [stdout]   16:     0x61f390b438e9 - std[70759c8f55707aa4]::sys::backtrace::__rust_end_short_backtrace::<std[70759c8f55707aa4]::panicking::panic_handler::{closure#0}, !>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:182:18
[INFO] [stdout]   17:     0x61f390b4ba2d - __rustc[8fa7c3cbc660c2b3]::rust_begin_unwind
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:679:5
[INFO] [stdout]   18:     0x61f390b8725c - core[df12db4294e9bfd3]::panicking::panic_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panicking.rs:80:14
[INFO] [stdout]   19:     0x61f390b86f82 - core[df12db4294e9bfd3]::result::unwrap_failed
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/result.rs:1871:5
[INFO] [stdout]   20:     0x61f3906aaed5 - <core[df12db4294e9bfd3]::result::Result<(), queue_workers[adfc8d6c25000dd3]::error::QueueWorkerError>>::expect
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/result.rs:1184:23
[INFO] [stdout]   21:     0x61f3906a38fb - concurrent_worker_integration[74c2bf3f656623f0]::test_concurrent_workers::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:226:31
[INFO] [stdout]   22:     0x61f3906b5082 - <core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>> as core[df12db4294e9bfd3]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/future/future.rs:133:9
[INFO] [stdout]   23:     0x61f3906b50fd - <core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>> as core[df12db4294e9bfd3]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/future/future.rs:133:9
[INFO] [stdout]   24:     0x61f3906d5bcd - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:733:70
[INFO] [stdout]   25:     0x61f3906d5af5 - tokio[48d4ccfe82f49eab]::task::coop::with_budget::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/task/coop/mod.rs:167:5
[INFO] [stdout]   26:     0x61f3906d5af5 - tokio[48d4ccfe82f49eab]::task::coop::budget::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/task/coop/mod.rs:133:5
[INFO] [stdout]   27:     0x61f3906d5af5 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:733:25
[INFO] [stdout]   28:     0x61f3906cd9f2 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Context>::enter::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:432:19
[INFO] [stdout]   29:     0x61f3906d4130 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:732:44
[INFO] [stdout]   30:     0x61f3906d3414 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:820:68
[INFO] [stdout]   31:     0x61f39067ad6b - <tokio[48d4ccfe82f49eab]::runtime::context::scoped::Scoped<tokio[48d4ccfe82f49eab]::runtime::scheduler::Context>>::set::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context/scoped.rs:40:9
[INFO] [stdout]   32:     0x61f3906e90e9 - tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler::<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context.rs:180:38
[INFO] [stdout]   33:     0x61f3906be64f - <std[70759c8f55707aa4]::thread::local::LocalKey<tokio[48d4ccfe82f49eab]::runtime::context::Context>>::try_with::<tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/local.rs:463:12
[INFO] [stdout]   34:     0x61f3906be1fe - <std[70759c8f55707aa4]::thread::local::LocalKey<tokio[48d4ccfe82f49eab]::runtime::context::Context>>::with::<tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/local.rs:427:20
[INFO] [stdout]   35:     0x61f3906e8a9d - tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler::<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context.rs:180:17
[INFO] [stdout]   36:     0x61f3906d0c90 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:820:27
[INFO] [stdout]   37:     0x61f3906d0f86 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:720:24
[INFO] [stdout]   38:     0x61f3906d2f23 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:200:33
[INFO] [stdout]   39:     0x61f3906c0478 - tokio[48d4ccfe82f49eab]::runtime::context::runtime::enter_runtime::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>::{closure#0}, ()>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context/runtime.rs:65:16
[INFO] [stdout]   40:     0x61f3906cd5b4 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:188:9
[INFO] [stdout]   41:     0x61f3906c458f - <tokio[48d4ccfe82f49eab]::runtime::runtime::Runtime>::block_on_inner::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/runtime.rs:368:52
[INFO] [stdout]   42:     0x61f3906c46d6 - <tokio[48d4ccfe82f49eab]::runtime::runtime::Runtime>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/runtime.rs:342:18
[INFO] [stdout]   43:     0x61f3906a5bc1 - concurrent_worker_integration[74c2bf3f656623f0]::test_concurrent_workers
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:264:35
[INFO] [stdout]   44:     0x61f39069e5a7 - concurrent_worker_integration[74c2bf3f656623f0]::test_concurrent_workers::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:209:35
[INFO] [stdout]   45:     0x61f3906e6fb6 - <concurrent_worker_integration[74c2bf3f656623f0]::test_concurrent_workers::{closure#0} as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   46:     0x61f3906fbbdb - <fn() -> core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   47:     0x61f3906fbbdb - test[9d35eded1c95d3be]::__rust_begin_short_backtrace::<core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>, fn() -> core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:733:18
[INFO] [stdout]   48:     0x61f390709245 - test[9d35eded1c95d3be]::run_test_in_process::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:756:74
[INFO] [stdout]   49:     0x61f390709245 - <core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   50:     0x61f390709245 - std[70759c8f55707aa4]::panicking::catch_unwind::do_call::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>, core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:576:43
[INFO] [stdout]   51:     0x61f390709245 - std[70759c8f55707aa4]::panicking::catch_unwind::<core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>, core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:544:19
[INFO] [stdout]   52:     0x61f390709245 - std[70759c8f55707aa4]::panic::catch_unwind::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>, core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panic.rs:359:14
[INFO] [stdout]   53:     0x61f390709245 - test[9d35eded1c95d3be]::run_test_in_process
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:756:27
[INFO] [stdout]   54:     0x61f390709245 - test[9d35eded1c95d3be]::run_test::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:677:43
[INFO] [stdout]   55:     0x61f390702b04 - test[9d35eded1c95d3be]::run_test::{closure#1}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:707:41
[INFO] [stdout]   56:     0x61f390702b04 - std[70759c8f55707aa4]::sys::backtrace::__rust_begin_short_backtrace::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:166:18
[INFO] [stdout]   57:     0x61f39070c3a2 - std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/lifecycle.rs:70:13
[INFO] [stdout]   58:     0x61f39070c3a2 - <core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   59:     0x61f39070c3a2 - std[70759c8f55707aa4]::panicking::catch_unwind::do_call::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:576:43
[INFO] [stdout]   60:     0x61f39070c3a2 - std[70759c8f55707aa4]::panicking::catch_unwind::<(), core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:544:19
[INFO] [stdout]   61:     0x61f39070c3a2 - std[70759c8f55707aa4]::panic::catch_unwind::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panic.rs:359:14
[INFO] [stdout]   62:     0x61f39070c3a2 - std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/lifecycle.rs:68:26
[INFO] [stdout]   63:     0x61f39070c3a2 - <std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1} as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   64:     0x61f390b6eab9 - <alloc[2182bb758b4b3781]::boxed::Box<dyn core[df12db4294e9bfd3]::ops::function::FnOnce<(), Output = ()> + core[df12db4294e9bfd3]::marker::Send> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2320:9
[INFO] [stdout]   65:     0x61f390b6eab9 - <std[70759c8f55707aa4]::sys::thread::unix::Thread>::new::thread_start
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/thread/unix.rs:123:17
[INFO] [stdout]   66:     0x794bb14dbdfa - <unknown>
[INFO] [stdout]   67:     0x794bb156f3d4 - clone
[INFO] [stdout]   68:                0x0 - <unknown>
[INFO] [stdout] 
[INFO] [stdout] ---- test_queue_persistence stdout ----
[INFO] [stdout] 
[INFO] [stdout] thread 'test_queue_persistence' (2033) panicked at tests/concurrent_worker_integration.rs:284:35:
[INFO] [stdout] Failed to push job: ConnectionError("Connection refused (os error 111)")
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0:     0x61f390b6f591 - std[70759c8f55707aa4]::backtrace_rs::backtrace::libunwind::trace
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9
[INFO] [stdout]    1:     0x61f390b6f591 - std[70759c8f55707aa4]::backtrace_rs::backtrace::trace_unsynchronized::<std[70759c8f55707aa4]::sys::backtrace::_print_fmt::{closure#1}>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14
[INFO] [stdout]    2:     0x61f390b6f591 - std[70759c8f55707aa4]::sys::backtrace::_print_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:74:9
[INFO] [stdout]    3:     0x61f390b6f591 - <<std[70759c8f55707aa4]::sys::backtrace::BacktraceLock>::print::DisplayBacktrace as core[df12db4294e9bfd3]::fmt::Display>::fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:44:26
[INFO] [stdout]    4:     0x61f390b8698a - <core[df12db4294e9bfd3]::fmt::rt::Argument>::fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/fmt/rt.rs:152:76
[INFO] [stdout]    5:     0x61f390b8698a - core[df12db4294e9bfd3]::fmt::write
[INFO] [stdout]    6:     0x61f390b740ac - core[df12db4294e9bfd3]::io::write::default_write_fmt::<alloc[2182bb758b4b3781]::vec::Vec<u8>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/io/write.rs:402:11
[INFO] [stdout]    7:     0x61f390b740ac - <alloc[2182bb758b4b3781]::vec::Vec<u8> as core[df12db4294e9bfd3]::io::write::Write>::write_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/io/write.rs:335:13
[INFO] [stdout]    8:     0x61f390b4ab96 - <std[70759c8f55707aa4]::sys::backtrace::BacktraceLock>::print
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:47:9
[INFO] [stdout]    9:     0x61f390b4ab96 - std[70759c8f55707aa4]::panicking::default_hook::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:292:27
[INFO] [stdout]   10:     0x61f390b674b9 - std[70759c8f55707aa4]::panicking::default_hook
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:316:9
[INFO] [stdout]   11:     0x61f3907088f0 - <alloc[2182bb758b4b3781]::boxed::Box<dyn for<'a, 'b> core[df12db4294e9bfd3]::ops::function::Fn<(&'a std[70759c8f55707aa4]::panic::PanicHookInfo<'b>,), Output = ()> + core[df12db4294e9bfd3]::marker::Send + core[df12db4294e9bfd3]::marker::Sync> as core[df12db4294e9bfd3]::ops::function::Fn<(&std[70759c8f55707aa4]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2334:9
[INFO] [stdout]   12:     0x61f3907088f0 - test[9d35eded1c95d3be]::test_main_inner::<test[9d35eded1c95d3be]::test_main_static::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:155:21
[INFO] [stdout]   13:     0x61f390b677e2 - <alloc[2182bb758b4b3781]::boxed::Box<dyn for<'a, 'b> core[df12db4294e9bfd3]::ops::function::Fn<(&'a std[70759c8f55707aa4]::panic::PanicHookInfo<'b>,), Output = ()> + core[df12db4294e9bfd3]::marker::Send + core[df12db4294e9bfd3]::marker::Sync> as core[df12db4294e9bfd3]::ops::function::Fn<(&std[70759c8f55707aa4]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2334:9
[INFO] [stdout]   14:     0x61f390b677e2 - std[70759c8f55707aa4]::panicking::panic_with_hook
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:823:13
[INFO] [stdout]   15:     0x61f390b4ac42 - std[70759c8f55707aa4]::panicking::panic_handler::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:688:13
[INFO] [stdout]   16:     0x61f390b438e9 - std[70759c8f55707aa4]::sys::backtrace::__rust_end_short_backtrace::<std[70759c8f55707aa4]::panicking::panic_handler::{closure#0}, !>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:182:18
[INFO] [stdout]   17:     0x61f390b4ba2d - __rustc[8fa7c3cbc660c2b3]::rust_begin_unwind
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:679:5
[INFO] [stdout]   18:     0x61f390b8725c - core[df12db4294e9bfd3]::panicking::panic_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panicking.rs:80:14
[INFO] [stdout]   19:     0x61f390b86f82 - core[df12db4294e9bfd3]::result::unwrap_failed
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/result.rs:1871:5
[INFO] [stdout]   20:     0x61f3906aaed5 - <core[df12db4294e9bfd3]::result::Result<(), queue_workers[adfc8d6c25000dd3]::error::QueueWorkerError>>::expect
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/result.rs:1184:23
[INFO] [stdout]   21:     0x61f3906a1e06 - concurrent_worker_integration[74c2bf3f656623f0]::test_queue_persistence::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:284:35
[INFO] [stdout]   22:     0x61f3906b5082 - <core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>> as core[df12db4294e9bfd3]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/future/future.rs:133:9
[INFO] [stdout]   23:     0x61f3906b50fd - <core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>> as core[df12db4294e9bfd3]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/future/future.rs:133:9
[INFO] [stdout]   24:     0x61f3906d5bcd - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:733:70
[INFO] [stdout]   25:     0x61f3906d5af5 - tokio[48d4ccfe82f49eab]::task::coop::with_budget::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/task/coop/mod.rs:167:5
[INFO] [stdout]   26:     0x61f3906d5af5 - tokio[48d4ccfe82f49eab]::task::coop::budget::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/task/coop/mod.rs:133:5
[INFO] [stdout]   27:     0x61f3906d5af5 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:733:25
[INFO] [stdout]   28:     0x61f3906cd9f2 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Context>::enter::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:432:19
[INFO] [stdout]   29:     0x61f3906d4130 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:732:44
[INFO] [stdout]   30:     0x61f3906d3414 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:820:68
[INFO] [stdout]   31:     0x61f39067ad6b - <tokio[48d4ccfe82f49eab]::runtime::context::scoped::Scoped<tokio[48d4ccfe82f49eab]::runtime::scheduler::Context>>::set::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context/scoped.rs:40:9
[INFO] [stdout]   32:     0x61f3906e90e9 - tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler::<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context.rs:180:38
[INFO] [stdout]   33:     0x61f3906be64f - <std[70759c8f55707aa4]::thread::local::LocalKey<tokio[48d4ccfe82f49eab]::runtime::context::Context>>::try_with::<tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/local.rs:463:12
[INFO] [stdout]   34:     0x61f3906be1fe - <std[70759c8f55707aa4]::thread::local::LocalKey<tokio[48d4ccfe82f49eab]::runtime::context::Context>>::with::<tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/local.rs:427:20
[INFO] [stdout]   35:     0x61f3906e8a9d - tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler::<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context.rs:180:17
[INFO] [stdout]   36:     0x61f3906d0c90 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:820:27
[INFO] [stdout]   37:     0x61f3906d0f86 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:720:24
[INFO] [stdout]   38:     0x61f3906d2f23 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:200:33
[INFO] [stdout]   39:     0x61f3906c0478 - tokio[48d4ccfe82f49eab]::runtime::context::runtime::enter_runtime::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>::{closure#0}, ()>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context/runtime.rs:65:16
[INFO] [stdout]   40:     0x61f3906cd5b4 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:188:9
[INFO] [stdout]   41:     0x61f3906c458f - <tokio[48d4ccfe82f49eab]::runtime::runtime::Runtime>::block_on_inner::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/runtime.rs:368:52
[INFO] [stdout]   42:     0x61f3906c46d6 - <tokio[48d4ccfe82f49eab]::runtime::runtime::Runtime>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/runtime.rs:342:18
[INFO] [stdout]   43:     0x61f3906a5a01 - concurrent_worker_integration[74c2bf3f656623f0]::test_queue_persistence
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:293:45
[INFO] [stdout]   44:     0x61f39069e577 - concurrent_worker_integration[74c2bf3f656623f0]::test_queue_persistence::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:271:34
[INFO] [stdout]   45:     0x61f3906e6f96 - <concurrent_worker_integration[74c2bf3f656623f0]::test_queue_persistence::{closure#0} as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   46:     0x61f3906fbbdb - <fn() -> core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   47:     0x61f3906fbbdb - test[9d35eded1c95d3be]::__rust_begin_short_backtrace::<core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>, fn() -> core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:733:18
[INFO] [stdout]   48:     0x61f390709245 - test[9d35eded1c95d3be]::run_test_in_process::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:756:74
[INFO] [stdout]   49:     0x61f390709245 - <core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   50:     0x61f390709245 - std[70759c8f55707aa4]::panicking::catch_unwind::do_call::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>, core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:576:43
[INFO] [stdout]   51:     0x61f390709245 - std[70759c8f55707aa4]::panicking::catch_unwind::<core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>, core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:544:19
[INFO] [stdout]   52:     0x61f390709245 - std[70759c8f55707aa4]::panic::catch_unwind::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>, core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panic.rs:359:14
[INFO] [stdout]   53:     0x61f390709245 - test[9d35eded1c95d3be]::run_test_in_process
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:756:27
[INFO] [stdout]   54:     0x61f390709245 - test[9d35eded1c95d3be]::run_test::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:677:43
[INFO] [stdout]   55:     0x61f390702b04 - test[9d35eded1c95d3be]::run_test::{closure#1}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:707:41
[INFO] [stdout]   56:     0x61f390702b04 - std[70759c8f55707aa4]::sys::backtrace::__rust_begin_short_backtrace::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:166:18
[INFO] [stdout]   57:     0x61f39070c3a2 - std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/lifecycle.rs:70:13
[INFO] [stdout]   58:     0x61f39070c3a2 - <core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   59:     0x61f39070c3a2 - std[70759c8f55707aa4]::panicking::catch_unwind::do_call::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:576:43
[INFO] [stdout]   60:     0x61f39070c3a2 - std[70759c8f55707aa4]::panicking::catch_unwind::<(), core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:544:19
[INFO] [stdout]   61:     0x61f39070c3a2 - std[70759c8f55707aa4]::panic::catch_unwind::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panic.rs:359:14
[INFO] [stdout]   62:     0x61f39070c3a2 - std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/lifecycle.rs:68:26
[INFO] [stdout]   63:     0x61f39070c3a2 - <std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1} as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   64:     0x61f390b6eab9 - <alloc[2182bb758b4b3781]::boxed::Box<dyn core[df12db4294e9bfd3]::ops::function::FnOnce<(), Output = ()> + core[df12db4294e9bfd3]::marker::Send> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2320:9
[INFO] [stdout]   65:     0x61f390b6eab9 - <std[70759c8f55707aa4]::sys::thread::unix::Thread>::new::thread_start
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/thread/unix.rs:123:17
[INFO] [stdout]   66:     0x794bb14dbdfa - <unknown>
[INFO] [stdout]   67:     0x794bb156f3d4 - clone
[INFO] [stdout]   68:                0x0 - <unknown>
[INFO] [stdout] 
[INFO] [stdout] ---- test_complete_workflow stdout ----
[INFO] [stdout] 
[INFO] [stdout] thread 'test_complete_workflow' (2031) panicked at tests/concurrent_worker_integration.rs:155:10:
[INFO] [stdout] Failed to push successful job: ConnectionError("Connection refused (os error 111)")
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0:     0x61f390b6f591 - std[70759c8f55707aa4]::backtrace_rs::backtrace::libunwind::trace
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9
[INFO] [stdout]    1:     0x61f390b6f591 - std[70759c8f55707aa4]::backtrace_rs::backtrace::trace_unsynchronized::<std[70759c8f55707aa4]::sys::backtrace::_print_fmt::{closure#1}>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14
[INFO] [stdout]    2:     0x61f390b6f591 - std[70759c8f55707aa4]::sys::backtrace::_print_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:74:9
[INFO] [stdout]    3:     0x61f390b6f591 - <<std[70759c8f55707aa4]::sys::backtrace::BacktraceLock>::print::DisplayBacktrace as core[df12db4294e9bfd3]::fmt::Display>::fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:44:26
[INFO] [stdout]    4:     0x61f390b8698a - <core[df12db4294e9bfd3]::fmt::rt::Argument>::fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/fmt/rt.rs:152:76
[INFO] [stdout]    5:     0x61f390b8698a - core[df12db4294e9bfd3]::fmt::write
[INFO] [stdout]    6:     0x61f390b740ac - core[df12db4294e9bfd3]::io::write::default_write_fmt::<alloc[2182bb758b4b3781]::vec::Vec<u8>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/io/write.rs:402:11
[INFO] [stdout]    7:     0x61f390b740ac - <alloc[2182bb758b4b3781]::vec::Vec<u8> as core[df12db4294e9bfd3]::io::write::Write>::write_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/io/write.rs:335:13
[INFO] [stdout]    8:     0x61f390b4ab96 - <std[70759c8f55707aa4]::sys::backtrace::BacktraceLock>::print
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:47:9
[INFO] [stdout]    9:     0x61f390b4ab96 - std[70759c8f55707aa4]::panicking::default_hook::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:292:27
[INFO] [stdout]   10:     0x61f390b674b9 - std[70759c8f55707aa4]::panicking::default_hook
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:316:9
[INFO] [stdout]   11:     0x61f3907088f0 - <alloc[2182bb758b4b3781]::boxed::Box<dyn for<'a, 'b> core[df12db4294e9bfd3]::ops::function::Fn<(&'a std[70759c8f55707aa4]::panic::PanicHookInfo<'b>,), Output = ()> + core[df12db4294e9bfd3]::marker::Send + core[df12db4294e9bfd3]::marker::Sync> as core[df12db4294e9bfd3]::ops::function::Fn<(&std[70759c8f55707aa4]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2334:9
[INFO] [stdout]   12:     0x61f3907088f0 - test[9d35eded1c95d3be]::test_main_inner::<test[9d35eded1c95d3be]::test_main_static::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:155:21
[INFO] [stdout]   13:     0x61f390b677e2 - <alloc[2182bb758b4b3781]::boxed::Box<dyn for<'a, 'b> core[df12db4294e9bfd3]::ops::function::Fn<(&'a std[70759c8f55707aa4]::panic::PanicHookInfo<'b>,), Output = ()> + core[df12db4294e9bfd3]::marker::Send + core[df12db4294e9bfd3]::marker::Sync> as core[df12db4294e9bfd3]::ops::function::Fn<(&std[70759c8f55707aa4]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2334:9
[INFO] [stdout]   14:     0x61f390b677e2 - std[70759c8f55707aa4]::panicking::panic_with_hook
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:823:13
[INFO] [stdout]   15:     0x61f390b4ac42 - std[70759c8f55707aa4]::panicking::panic_handler::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:688:13
[INFO] [stdout]   16:     0x61f390b438e9 - std[70759c8f55707aa4]::sys::backtrace::__rust_end_short_backtrace::<std[70759c8f55707aa4]::panicking::panic_handler::{closure#0}, !>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:182:18
[INFO] [stdout]   17:     0x61f390b4ba2d - __rustc[8fa7c3cbc660c2b3]::rust_begin_unwind
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:679:5
[INFO] [stdout]   18:     0x61f390b8725c - core[df12db4294e9bfd3]::panicking::panic_fmt
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panicking.rs:80:14
[INFO] [stdout]   19:     0x61f390b86f82 - core[df12db4294e9bfd3]::result::unwrap_failed
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/result.rs:1871:5
[INFO] [stdout]   20:     0x61f3906aaed5 - <core[df12db4294e9bfd3]::result::Result<(), queue_workers[adfc8d6c25000dd3]::error::QueueWorkerError>>::expect
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/result.rs:1184:23
[INFO] [stdout]   21:     0x61f3906a005a - concurrent_worker_integration[74c2bf3f656623f0]::test_complete_workflow::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:155:10
[INFO] [stdout]   22:     0x61f3906b5082 - <core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>> as core[df12db4294e9bfd3]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/future/future.rs:133:9
[INFO] [stdout]   23:     0x61f3906b50fd - <core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>> as core[df12db4294e9bfd3]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/future/future.rs:133:9
[INFO] [stdout]   24:     0x61f3906d5bcd - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:733:70
[INFO] [stdout]   25:     0x61f3906d5af5 - tokio[48d4ccfe82f49eab]::task::coop::with_budget::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/task/coop/mod.rs:167:5
[INFO] [stdout]   26:     0x61f3906d5af5 - tokio[48d4ccfe82f49eab]::task::coop::budget::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/task/coop/mod.rs:133:5
[INFO] [stdout]   27:     0x61f3906d5af5 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:733:25
[INFO] [stdout]   28:     0x61f3906cd9f2 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Context>::enter::<core[df12db4294e9bfd3]::task::poll::Poll<()>, <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:432:19
[INFO] [stdout]   29:     0x61f3906d4130 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:732:44
[INFO] [stdout]   30:     0x61f3906d3414 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:820:68
[INFO] [stdout]   31:     0x61f39067ad6b - <tokio[48d4ccfe82f49eab]::runtime::context::scoped::Scoped<tokio[48d4ccfe82f49eab]::runtime::scheduler::Context>>::set::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context/scoped.rs:40:9
[INFO] [stdout]   32:     0x61f3906e90e9 - tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler::<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context.rs:180:38
[INFO] [stdout]   33:     0x61f3906be64f - <std[70759c8f55707aa4]::thread::local::LocalKey<tokio[48d4ccfe82f49eab]::runtime::context::Context>>::try_with::<tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/local.rs:463:12
[INFO] [stdout]   34:     0x61f3906be1fe - <std[70759c8f55707aa4]::thread::local::LocalKey<tokio[48d4ccfe82f49eab]::runtime::context::Context>>::with::<tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>)>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/local.rs:427:20
[INFO] [stdout]   35:     0x61f3906e8a9d - tokio[48d4ccfe82f49eab]::runtime::context::set_scheduler::<(alloc[2182bb758b4b3781]::boxed::Box<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::Core>, core[df12db4294e9bfd3]::option::Option<()>), <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context.rs:180:17
[INFO] [stdout]   36:     0x61f3906d0c90 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>::{closure#0}, core[df12db4294e9bfd3]::option::Option<()>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:820:27
[INFO] [stdout]   37:     0x61f3906d0f86 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:720:24
[INFO] [stdout]   38:     0x61f3906d2f23 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:200:33
[INFO] [stdout]   39:     0x61f3906c0478 - tokio[48d4ccfe82f49eab]::runtime::context::runtime::enter_runtime::<<tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>::{closure#0}, ()>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/context/runtime.rs:65:16
[INFO] [stdout]   40:     0x61f3906cd5b4 - <tokio[48d4ccfe82f49eab]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/scheduler/current_thread/mod.rs:188:9
[INFO] [stdout]   41:     0x61f3906c458f - <tokio[48d4ccfe82f49eab]::runtime::runtime::Runtime>::block_on_inner::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/runtime.rs:368:52
[INFO] [stdout]   42:     0x61f3906c46d6 - <tokio[48d4ccfe82f49eab]::runtime::runtime::Runtime>::block_on::<core[df12db4294e9bfd3]::pin::Pin<&mut dyn core[df12db4294e9bfd3]::future::future::Future<Output = ()>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.44.2/src/runtime/runtime.rs:342:18
[INFO] [stdout]   43:     0x61f3906a5841 - concurrent_worker_integration[74c2bf3f656623f0]::test_complete_workflow
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:205:45
[INFO] [stdout]   44:     0x61f39069e547 - concurrent_worker_integration[74c2bf3f656623f0]::test_complete_workflow::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:121:34
[INFO] [stdout]   45:     0x61f3906e6f76 - <concurrent_worker_integration[74c2bf3f656623f0]::test_complete_workflow::{closure#0} as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   46:     0x61f3906fbbdb - <fn() -> core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   47:     0x61f3906fbbdb - test[9d35eded1c95d3be]::__rust_begin_short_backtrace::<core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>, fn() -> core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:733:18
[INFO] [stdout]   48:     0x61f390709245 - test[9d35eded1c95d3be]::run_test_in_process::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:756:74
[INFO] [stdout]   49:     0x61f390709245 - <core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   50:     0x61f390709245 - std[70759c8f55707aa4]::panicking::catch_unwind::do_call::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>, core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:576:43
[INFO] [stdout]   51:     0x61f390709245 - std[70759c8f55707aa4]::panicking::catch_unwind::<core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>, core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:544:19
[INFO] [stdout]   52:     0x61f390709245 - std[70759c8f55707aa4]::panic::catch_unwind::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<test[9d35eded1c95d3be]::run_test_in_process::{closure#0}>, core[df12db4294e9bfd3]::result::Result<(), alloc[2182bb758b4b3781]::string::String>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panic.rs:359:14
[INFO] [stdout]   53:     0x61f390709245 - test[9d35eded1c95d3be]::run_test_in_process
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:756:27
[INFO] [stdout]   54:     0x61f390709245 - test[9d35eded1c95d3be]::run_test::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:677:43
[INFO] [stdout]   55:     0x61f390702b04 - test[9d35eded1c95d3be]::run_test::{closure#1}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/test/src/lib.rs:707:41
[INFO] [stdout]   56:     0x61f390702b04 - std[70759c8f55707aa4]::sys::backtrace::__rust_begin_short_backtrace::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/backtrace.rs:166:18
[INFO] [stdout]   57:     0x61f39070c3a2 - std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/lifecycle.rs:70:13
[INFO] [stdout]   58:     0x61f39070c3a2 - <core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   59:     0x61f39070c3a2 - std[70759c8f55707aa4]::panicking::catch_unwind::do_call::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:576:43
[INFO] [stdout]   60:     0x61f39070c3a2 - std[70759c8f55707aa4]::panicking::catch_unwind::<(), core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panicking.rs:544:19
[INFO] [stdout]   61:     0x61f39070c3a2 - std[70759c8f55707aa4]::panic::catch_unwind::<core[df12db4294e9bfd3]::panic::unwind_safe::AssertUnwindSafe<std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/panic.rs:359:14
[INFO] [stdout]   62:     0x61f39070c3a2 - std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked::<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/thread/lifecycle.rs:68:26
[INFO] [stdout]   63:     0x61f39070c3a2 - <std[70759c8f55707aa4]::thread::lifecycle::spawn_unchecked<test[9d35eded1c95d3be]::run_test::{closure#1}, ()>::{closure#1} as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0}
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   64:     0x61f390b6eab9 - <alloc[2182bb758b4b3781]::boxed::Box<dyn core[df12db4294e9bfd3]::ops::function::FnOnce<(), Output = ()> + core[df12db4294e9bfd3]::marker::Send> as core[df12db4294e9bfd3]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/alloc/src/boxed.rs:2320:9
[INFO] [stdout]   65:     0x61f390b6eab9 - <std[70759c8f55707aa4]::sys::thread::unix::Thread>::new::thread_start
[INFO] [stdout]                                at /rustc/dfb0accb7f508ae8be965d8629557221c889dd98/library/std/src/sys/thread/unix.rs:123:17
[INFO] [stdout]   66:     0x794bb14dbdfa - <unknown>
[INFO] [stdout]   67:     0x794bb156f3d4 - clone
[INFO] [stdout]   68:                0x0 - <unknown>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     test_complete_workflow
[INFO] [stdout]     test_concurrent_workers
[INFO] [stdout]     test_queue_persistence
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 2 passed; 3 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.11s
[INFO] [stdout] 
[INFO] [stderr] error: test failed, to rerun pass `--test concurrent_worker_integration`
[INFO] running `Command { std: "docker" "inspect" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe", kill_on_drop: false }`
[INFO] [stdout] 22e641c66053b0f6afcb563e2b463e0903918326bad2fe3e35b37fd135ed6afe
