[INFO] cloning repository https://github.com/armn3t/queue-workers [INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/armn3t/queue-workers" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Farmn3t%2Fqueue-workers", kill_on_drop: false }` [INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Farmn3t%2Fqueue-workers'... [INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }` [INFO] [stdout] ed502108372e40e98853f7ea7d90576a4c39798c [INFO] testing armn3t/queue-workers/ed502108372e40e98853f7ea7d90576a4c39798c against master#ec6f9a5b4413f74386267ef8efc93712c2ce6db6 for pr-155739-1 [INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Farmn3t%2Fqueue-workers" "/workspace/builds/worker-7-tc1/source", kill_on_drop: false }` [INFO] [stderr] Cloning into '/workspace/builds/worker-7-tc1/source'... [INFO] [stderr] done. [INFO] started tweaking git repo https://github.com/armn3t/queue-workers [INFO] finished tweaking git repo https://github.com/armn3t/queue-workers [INFO] tweaked toml for git repo https://github.com/armn3t/queue-workers written to /workspace/builds/worker-7-tc1/source/Cargo.toml [INFO] validating manifest of git repo https://github.com/armn3t/queue-workers on toolchain ec6f9a5b4413f74386267ef8efc93712c2ce6db6 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+ec6f9a5b4413f74386267ef8efc93712c2ce6db6" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate git repo https://github.com/armn3t/queue-workers 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" "+ec6f9a5b4413f74386267ef8efc93712c2ce6db6" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Updating crates.io index [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded uuid v1.16.0 [INFO] [stderr] Downloaded wit-bindgen-rt v0.39.0 [INFO] [stderr] Downloaded tracing-test-macro v0.2.5 [INFO] [stderr] Downloaded tracing-serde v0.2.0 [INFO] [stderr] Downloaded utf16_iter v1.0.5 [INFO] [stderr] Downloaded test-log v0.2.17 [INFO] [stderr] Downloaded icu_provider_macros v1.5.0 [INFO] [stderr] Downloaded futures-sink v0.3.31 [INFO] [stderr] Downloaded zerofrom-derive v0.1.6 [INFO] [stderr] Downloaded yoke-derive v0.7.5 [INFO] [stderr] Downloaded test-log-macros v0.2.17 [INFO] [stderr] Downloaded is_terminal_polyfill v1.70.1 [INFO] [stderr] Downloaded colorchoice v1.0.3 [INFO] [stderr] Downloaded zerofrom v0.1.6 [INFO] [stderr] Downloaded matchers v0.2.0 [INFO] [stderr] Downloaded anstyle v1.0.10 [INFO] [stderr] Downloaded utf8parse v0.2.2 [INFO] [stderr] Downloaded anstyle-query v1.1.2 [INFO] [stderr] Downloaded adler2 v2.0.0 [INFO] [stderr] Downloaded icu_normalizer v1.5.0 [INFO] [stderr] Downloaded itoa v1.0.15 [INFO] [stderr] Downloaded anstyle-wincon v3.0.7 [INFO] [stderr] Downloaded tracing-test v0.2.5 [INFO] [stderr] Downloaded futures-task v0.3.31 [INFO] [stderr] Downloaded windows-targets v0.52.6 [INFO] [stderr] Downloaded tokio-macros v2.5.0 [INFO] [stderr] Downloaded env_filter v0.1.3 [INFO] [stderr] Downloaded idna_adapter v1.2.0 [INFO] [stderr] Downloaded futures-core v0.3.31 [INFO] [stderr] Downloaded stable_deref_trait v1.2.0 [INFO] [stderr] Downloaded pin-project-lite v0.2.16 [INFO] [stderr] Downloaded rustc-demangle v0.1.24 [INFO] [stderr] Downloaded utf8_iter v1.0.4 [INFO] [stderr] Downloaded synstructure v0.13.1 [INFO] [stderr] Downloaded yoke v0.7.5 [INFO] [stderr] Downloaded displaydoc v0.2.5 [INFO] [stderr] Downloaded writeable v0.5.5 [INFO] [stderr] Downloaded icu_locid_transform v1.5.0 [INFO] [stderr] Downloaded signal-hook-registry v1.4.2 [INFO] [stderr] Downloaded thiserror v2.0.12 [INFO] [stderr] Downloaded write16 v1.0.0 [INFO] [stderr] Downloaded windows-interface v0.59.1 [INFO] [stderr] Downloaded valuable v0.1.1 [INFO] [stderr] Downloaded redox_syscall v0.5.11 [INFO] [stderr] Downloaded lock_api v0.4.12 [INFO] [stderr] Downloaded env_logger v0.11.8 [INFO] [stderr] Downloaded sha1_smol v1.0.1 [INFO] [stderr] Downloaded futures-io v0.3.31 [INFO] [stderr] Downloaded log v0.4.27 [INFO] [stderr] Downloaded nu-ansi-term v0.50.1 [INFO] [stderr] Downloaded autocfg v1.4.0 [INFO] [stderr] Downloaded anstyle-parse v0.2.6 [INFO] [stderr] Downloaded zerovec-derive v0.10.3 [INFO] [stderr] Downloaded tinystr v0.7.6 [INFO] [stderr] Downloaded litemap v0.7.5 [INFO] [stderr] Downloaded futures-macro v0.3.31 [INFO] [stderr] Downloaded wasm-bindgen-shared v0.2.100 [INFO] [stderr] Downloaded windows-result v0.3.2 [INFO] [stderr] Downloaded getrandom v0.3.2 [INFO] [stderr] Downloaded tracing-attributes v0.1.28 [INFO] [stderr] Downloaded unicode-ident v1.0.18 [INFO] [stderr] Downloaded quote v1.0.40 [INFO] [stderr] Downloaded icu_locid_transform_data v1.5.1 [INFO] [stderr] Downloaded parking_lot_core v0.9.10 [INFO] [stderr] Downloaded serde_derive v1.0.219 [INFO] [stderr] Downloaded addr2line v0.24.2 [INFO] [stderr] Downloaded thiserror-impl v2.0.12 [INFO] [stderr] Downloaded anstream v0.6.18 [INFO] [stderr] Downloaded serde v1.0.219 [INFO] [stderr] Downloaded bitflags v2.9.0 [INFO] [stderr] Downloaded once_cell v1.21.3 [INFO] [stderr] Downloaded smallvec v1.15.0 [INFO] [stderr] Downloaded ryu v1.0.20 [INFO] [stderr] Downloaded socket2 v0.5.9 [INFO] [stderr] Downloaded parking_lot v0.12.3 [INFO] [stderr] Downloaded icu_properties v1.5.1 [INFO] [stderr] Downloaded icu_provider v1.5.0 [INFO] [stderr] Downloaded icu_locid v1.5.0 [INFO] [stderr] Downloaded proc-macro2 v1.0.94 [INFO] [stderr] Downloaded tracing-core v0.1.33 [INFO] [stderr] Downloaded miniz_oxide v0.8.5 [INFO] [stderr] Downloaded r-efi v5.2.0 [INFO] [stderr] Downloaded windows-implement v0.60.0 [INFO] [stderr] Downloaded bytes v1.10.1 [INFO] [stderr] Downloaded url v2.5.4 [INFO] [stderr] Downloaded icu_normalizer_data v1.5.1 [INFO] [stderr] Downloaded async-trait v0.1.88 [INFO] [stderr] Downloaded windows-link v0.1.1 [INFO] [stderr] Downloaded wasm-bindgen-macro v0.2.100 [INFO] [stderr] Downloaded windows-strings v0.4.0 [INFO] [stderr] Downloaded memchr v2.7.4 [INFO] [stderr] Downloaded icu_collections v1.5.0 [INFO] [stderr] Downloaded tracing v0.1.41 [INFO] [stderr] Downloaded backtrace v0.3.74 [INFO] [stderr] Downloaded wasm-bindgen-macro-support v0.2.100 [INFO] [stderr] Downloaded rustversion v1.0.20 [INFO] [stderr] Downloaded zerovec v0.10.4 [INFO] [stderr] Downloaded mio v1.0.3 [INFO] [stderr] Downloaded idna v1.0.3 [INFO] [stderr] Downloaded tokio-util v0.7.14 [INFO] [stderr] Downloaded wasm-bindgen-backend v0.2.100 [INFO] [stderr] Downloaded wasi v0.14.2+wasi-0.2.4 [INFO] [stderr] Downloaded serde_json v1.0.140 [INFO] [stderr] Downloaded futures-channel v0.3.31 [INFO] [stderr] Downloaded futures-executor v0.3.31 [INFO] [stderr] Downloaded icu_properties_data v1.5.1 [INFO] [stderr] Downloaded futures v0.3.31 [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 tracing-subscriber v0.3.20 [INFO] [stderr] Downloaded core-foundation-sys v0.8.7 [INFO] [stderr] Downloaded js-sys v0.3.77 [INFO] [stderr] Downloaded gimli v0.31.1 [INFO] [stderr] Downloaded num-traits v0.2.19 [INFO] [stderr] Downloaded arc-swap v1.7.1 [INFO] [stderr] Downloaded redis v0.29.5 [INFO] [stderr] Downloaded syn v2.0.100 [INFO] [stderr] Downloaded bumpalo v3.17.0 [INFO] [stderr] Downloaded cc v1.2.19 [INFO] [stderr] Downloaded combine v4.6.7 [INFO] [stderr] Downloaded object v0.36.7 [INFO] [stderr] Downloaded num-bigint v0.4.6 [INFO] [stderr] Downloaded futures-util v0.3.31 [INFO] [stderr] Downloaded regex-syntax v0.8.5 [INFO] [stderr] Downloaded windows_x86_64_gnullvm v0.52.6 [INFO] [stderr] Downloaded windows_aarch64_gnullvm v0.52.6 [INFO] [stderr] Downloaded windows_i686_gnullvm v0.52.6 [INFO] [stderr] Downloaded chrono v0.4.40 [INFO] [stderr] Downloaded regex-automata v0.4.9 [INFO] [stderr] Downloaded libc v0.2.171 [INFO] [stderr] Downloaded windows_x86_64_gnu v0.52.6 [INFO] [stderr] Downloaded tokio v1.44.2 [INFO] [stderr] Downloaded windows_x86_64_msvc v0.52.6 [INFO] [stderr] Downloaded windows_i686_gnu v0.52.6 [INFO] [stderr] Downloaded windows_aarch64_msvc v0.52.6 [INFO] [stderr] Downloaded windows_i686_msvc v0.52.6 [INFO] [stderr] Downloaded windows-sys v0.59.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+ec6f9a5b4413f74386267ef8efc93712c2ce6db6" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 03114b19eab8797c190808d0a4052794604c812cf0095c69ee07166ec79f8b13 [INFO] running `Command { std: "docker" "start" "-a" "03114b19eab8797c190808d0a4052794604c812cf0095c69ee07166ec79f8b13", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "03114b19eab8797c190808d0a4052794604c812cf0095c69ee07166ec79f8b13", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "03114b19eab8797c190808d0a4052794604c812cf0095c69ee07166ec79f8b13", kill_on_drop: false }` [INFO] [stdout] 03114b19eab8797c190808d0a4052794604c812cf0095c69ee07166ec79f8b13 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+ec6f9a5b4413f74386267ef8efc93712c2ce6db6" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 98b06cffd9a8bed6149d4d0f93bb4925df91c1eccd0ac595b013fdd452364b8f [INFO] running `Command { std: "docker" "start" "-a" "98b06cffd9a8bed6149d4d0f93bb4925df91c1eccd0ac595b013fdd452364b8f", 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 stable_deref_trait v1.2.0 [INFO] [stderr] Compiling smallvec v1.15.0 [INFO] [stderr] Compiling icu_locid_transform_data v1.5.1 [INFO] [stderr] Compiling litemap v0.7.5 [INFO] [stderr] Compiling writeable v0.5.5 [INFO] [stderr] Compiling icu_properties_data v1.5.1 [INFO] [stderr] Compiling cfg-if v1.0.0 [INFO] [stderr] Compiling icu_normalizer_data v1.5.1 [INFO] [stderr] Compiling futures-core v0.3.31 [INFO] [stderr] Compiling futures-sink v0.3.31 [INFO] [stderr] Compiling pin-project-lite v0.2.16 [INFO] [stderr] Compiling parking_lot_core v0.9.10 [INFO] [stderr] Compiling memchr v2.7.4 [INFO] [stderr] Compiling scopeguard v1.2.0 [INFO] [stderr] Compiling write16 v1.0.0 [INFO] [stderr] Compiling utf8_iter v1.0.4 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling utf16_iter v1.0.5 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling futures-task v0.3.31 [INFO] [stderr] Compiling pin-utils v0.1.0 [INFO] [stderr] Compiling bytes v1.10.1 [INFO] [stderr] Compiling futures-io v0.3.31 [INFO] [stderr] Compiling percent-encoding v2.3.1 [INFO] [stderr] Compiling getrandom v0.3.2 [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 thiserror v2.0.12 [INFO] [stderr] Compiling form_urlencoded v1.2.1 [INFO] [stderr] Compiling itoa v1.0.15 [INFO] [stderr] Compiling serde_json v1.0.140 [INFO] [stderr] Compiling ryu v1.0.20 [INFO] [stderr] Compiling arc-swap v1.7.1 [INFO] [stderr] Compiling sha1_smol v1.0.1 [INFO] [stderr] Compiling iana-time-zone v0.1.63 [INFO] [stderr] Compiling log v0.4.27 [INFO] [stderr] Compiling socket2 v0.5.9 [INFO] [stderr] Compiling signal-hook-registry v1.4.2 [INFO] [stderr] Compiling mio v1.0.3 [INFO] [stderr] Compiling num_cpus v1.16.0 [INFO] [stderr] Compiling quote v1.0.40 [INFO] [stderr] Compiling num-integer v0.1.46 [INFO] [stderr] Compiling syn v2.0.100 [INFO] [stderr] Compiling parking_lot v0.12.3 [INFO] [stderr] Compiling num-bigint v0.4.6 [INFO] [stderr] Compiling synstructure v0.13.1 [INFO] [stderr] Compiling zerofrom-derive v0.1.6 [INFO] [stderr] Compiling yoke-derive v0.7.5 [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 futures-util v0.3.31 [INFO] [stderr] Compiling tokio v1.44.2 [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 tokio-util v0.7.14 [INFO] [stderr] Compiling combine v4.6.7 [INFO] [stderr] Compiling chrono v0.4.40 [INFO] [stderr] Compiling uuid v1.16.0 [INFO] [stderr] Compiling icu_normalizer v1.5.0 [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 42.29s [INFO] running `Command { std: "docker" "inspect" "98b06cffd9a8bed6149d4d0f93bb4925df91c1eccd0ac595b013fdd452364b8f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "98b06cffd9a8bed6149d4d0f93bb4925df91c1eccd0ac595b013fdd452364b8f", kill_on_drop: false }` [INFO] [stdout] 98b06cffd9a8bed6149d4d0f93bb4925df91c1eccd0ac595b013fdd452364b8f [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+ec6f9a5b4413f74386267ef8efc93712c2ce6db6" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] a2e110ab332c62e278e88a3fb7456a36ff8df923f57e0845f9bcb77e59b0126a [INFO] running `Command { std: "docker" "start" "-a" "a2e110ab332c62e278e88a3fb7456a36ff8df923f57e0845f9bcb77e59b0126a", kill_on_drop: false }` [INFO] [stderr] Compiling once_cell v1.21.3 [INFO] [stderr] Compiling log v0.4.27 [INFO] [stderr] Compiling regex-syntax v0.8.5 [INFO] [stderr] Compiling utf8parse v0.2.2 [INFO] [stderr] Compiling tracing-attributes v0.1.28 [INFO] [stderr] Compiling anstyle-query v1.1.2 [INFO] [stderr] Compiling lazy_static v1.5.0 [INFO] [stderr] Compiling is_terminal_polyfill v1.70.1 [INFO] [stderr] Compiling anstyle v1.0.10 [INFO] [stderr] Compiling colorchoice v1.0.3 [INFO] [stderr] Compiling nu-ansi-term v0.50.1 [INFO] [stderr] Compiling tracing-test-macro v0.2.5 [INFO] [stderr] Compiling test-log-macros v0.2.17 [INFO] [stderr] Compiling anstyle-parse v0.2.6 [INFO] [stderr] Compiling env_filter v0.1.3 [INFO] [stderr] Compiling queue_workers v0.5.1 (/opt/rustwide/workdir) [INFO] [stderr] Compiling sharded-slab v0.1.7 [INFO] [stderr] Compiling tracing-core v0.1.33 [INFO] [stderr] Compiling thread_local v1.1.8 [INFO] [stderr] Compiling anstream v0.6.18 [INFO] [stderr] Compiling tracing-serde v0.2.0 [INFO] [stderr] Compiling tracing-log v0.2.0 [INFO] [stderr] Compiling env_logger v0.11.8 [INFO] [stderr] Compiling test-log v0.2.17 [INFO] [stderr] Compiling regex-automata v0.4.9 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling matchers v0.2.0 [INFO] [stderr] Compiling tracing-subscriber v0.3.20 [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 18.69s [INFO] running `Command { std: "docker" "inspect" "a2e110ab332c62e278e88a3fb7456a36ff8df923f57e0845f9bcb77e59b0126a", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a2e110ab332c62e278e88a3fb7456a36ff8df923f57e0845f9bcb77e59b0126a", kill_on_drop: false }` [INFO] [stdout] a2e110ab332c62e278e88a3fb7456a36ff8df923f57e0845f9bcb77e59b0126a [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+ec6f9a5b4413f74386267ef8efc93712c2ce6db6" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 6289cb6e9047009af23067b56fe11ad71afcade6f1893cada7987af6b128417e [INFO] running `Command { std: "docker" "start" "-a" "6289cb6e9047009af23067b56fe11ad71afcade6f1893cada7987af6b128417e", 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.15s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/queue_workers-540d32eb25abe7b8) [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] test job::tests::test_clone ... ok [INFO] [stdout] test job::tests::test_new_job_metadata ... ok [INFO] [stdout] test job::tests::test_update_status ... ok [INFO] [stdout] test job::tests::test_serialization ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.16s [INFO] [stdout] [INFO] [stderr] Running tests/concurrent_worker.rs (/opt/rustwide/target/debug/deps/concurrent_worker-223e465cb91ee5d2) [INFO] [stdout] [INFO] [stdout] running 20 tests [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962207Z","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_job_respects_worker_config_retry_limit","threadId":"ThreadId(8)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962266Z","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_completes_job_during_shutdown","threadId":"ThreadId(4)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962417Z","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_job_respects_worker_config_retry_limit","threadId":"ThreadId(8)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962492Z","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_job_respects_worker_config_retry_limit","threadId":"ThreadId(8)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962494Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962586Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962635Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962684Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962668Z","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_graceful_shutdown_cancels_ongoing_job","threadId":"ThreadId(5)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962771Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962814Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962805Z","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_cancels_ongoing_job","threadId":"ThreadId(5)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962803Z","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_parallel_execution","threadId":"ThreadId(15)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962862Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962861Z","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_graceful_shutdown_cancels_ongoing_job","threadId":"ThreadId(5)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962875Z","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-05-15T03:28:13.962900Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962924Z","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-05-15T03:28:13.962938Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962993Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962998Z","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-05-15T03:28:13.963043Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963048Z","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-05-15T03:28:13.963084Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963106Z","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-05-15T03:28:13.963127Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963151Z","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-05-15T03:28:13.963166Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963203Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963246Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963284Z","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_job_execution_order","threadId":"ThreadId(7)"} [INFO] [stdout] test common::tests::test_logging_levels ... ok [INFO] [stdout] test common::tests::test_span_logging ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.962485Z","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_completes_job_during_shutdown","threadId":"ThreadId(4)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.963709Z","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_completes_job_during_shutdown","threadId":"ThreadId(4)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.964935Z","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_completes_job_during_shutdown","threadId":"ThreadId(4)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.968414Z","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_completes_job_during_shutdown","threadId":"ThreadId(4)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.965545Z","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_job_retries_once","threadId":"ThreadId(9)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.970433Z","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_job_retries_once","threadId":"ThreadId(9)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.970500Z","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_job_retries_once","threadId":"ThreadId(9)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.965777Z","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_job_retries_twice","threadId":"ThreadId(10)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.970699Z","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_job_retries_twice","threadId":"ThreadId(10)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.970753Z","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_job_retries_twice","threadId":"ThreadId(10)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.966072Z","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_job_retries_until_it_fails","threadId":"ThreadId(11)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.970883Z","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_job_retries_until_it_fails","threadId":"ThreadId(11)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.970936Z","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_job_retries_until_it_fails","threadId":"ThreadId(11)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.966298Z","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_job_succeeds_without_retries","threadId":"ThreadId(12)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971089Z","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_job_succeeds_without_retries","threadId":"ThreadId(12)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971143Z","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_job_succeeds_without_retries","threadId":"ThreadId(12)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971256Z","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_job_succeeds_without_retries","threadId":"ThreadId(12)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971308Z","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_job_succeeds_without_retries","threadId":"ThreadId(12)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.966549Z","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_leaves_jobs_in_queue_on_shutdown","threadId":"ThreadId(13)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971476Z","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_leaves_jobs_in_queue_on_shutdown","threadId":"ThreadId(13)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971524Z","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_leaves_jobs_in_queue_on_shutdown","threadId":"ThreadId(13)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971627Z","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_leaves_jobs_in_queue_on_shutdown","threadId":"ThreadId(13)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.966787Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971749Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971796Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971839Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971883Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971939Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.971992Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972031Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972067Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972128Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972173Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972213Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972255Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972298Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972338Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972406Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972444Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972483Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972524Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972564Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972598Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972637Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972676Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972712Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972761Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972802Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972841Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972884Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972923Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.972971Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973014Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973056Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973117Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973172Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973265Z","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_multiple_jobs","threadId":"ThreadId(14)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973465Z","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_succeeds_without_retries","threadId":"ThreadId(12)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973635Z","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_once","threadId":"ThreadId(9)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.967031Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.967085Z","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_respects_worker_config_retry_limit","threadId":"ThreadId(8)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973786Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973844Z","level":"ERROR","fields":{"message":"Job failed to execute: Unknown error: Simulated queue error","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":135},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":135,"threadName":"test_concurrent_worker_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.967255Z","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_respects_concurrency_limit","threadId":"ThreadId(17)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973887Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973921Z","level":"ERROR","fields":{"message":"Job failed to execute: Unknown error: Simulated queue error","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":135},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":135,"threadName":"test_concurrent_worker_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973911Z","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-05-15T03:28:13.973970Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.973979Z","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-05-15T03:28:13.974007Z","level":"ERROR","fields":{"message":"Job failed to execute: Unknown error: Simulated queue error","log.target":"queue_workers::concurrent_worker","log.module_path":"queue_workers::concurrent_worker","log.file":"src/concurrent_worker.rs","log.line":135},"target":"queue_workers::concurrent_worker","filename":"src/concurrent_worker.rs","line_number":135,"threadName":"test_concurrent_worker_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.974048Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.974047Z","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-05-15T03:28:13.974090Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.974089Z","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-05-15T03:28:13.974147Z","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-05-15T03:28:13.974191Z","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-05-15T03:28:13.974243Z","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-05-15T03:28:13.974300Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 50ms 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_cancels_ongoing_job","threadId":"ThreadId(5)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.974327Z","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-05-15T03:28:13.974705Z","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_completes_job_during_shutdown","threadId":"ThreadId(4)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.975000Z","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_respects_worker_config_retry_limit","threadId":"ThreadId(8)"} [INFO] [stdout] test test_concurrent_worker_job_respects_worker_config_retry_limit ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.975302Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.975444Z","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_queue_errors","threadId":"ThreadId(16)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.977441Z","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_shutdown_with_empty_queue","threadId":"ThreadId(20)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.977650Z","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_shutdown_with_empty_queue","threadId":"ThreadId(20)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.978559Z","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_once","threadId":"ThreadId(9)"} [INFO] [stdout] test test_concurrent_worker_job_retries_once ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.979127Z","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-05-15T03:28:13.979216Z","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-05-15T03:28:13.979297Z","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-05-15T03:28:13.979417Z","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-05-15T03:28:13.979731Z","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-05-15T03:28:13.981519Z","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_shutdown_signal_channel_closed","threadId":"ThreadId(19)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.981738Z","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_shutdown_signal_channel_closed","threadId":"ThreadId(19)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.981930Z","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_shutdown_signal_channel_closed","threadId":"ThreadId(19)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.983151Z","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-05-15T03:28:13.983274Z","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-05-15T03:28:13.983167Z","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_until_it_fails","threadId":"ThreadId(11)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.986739Z","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_until_it_fails","threadId":"ThreadId(11)"} [INFO] [stdout] test test_concurrent_worker_job_retries_until_it_fails ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:13.994765Z","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-05-15T03:28:13.994865Z","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-05-15T03:28:13.994905Z","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-05-15T03:28:13.994945Z","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-05-15T03:28:13.994999Z","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-05-15T03:28:13.995034Z","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-05-15T03:28:13.997433Z","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-05-15T03:28:13.997511Z","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-05-15T03:28:13.997550Z","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-05-15T03:28:13.997587Z","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-05-15T03:28:13.997635Z","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-05-15T03:28:13.997672Z","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-05-15T03:28:14.011104Z","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-05-15T03:28:14.011275Z","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-05-15T03:28:14.011432Z","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-05-15T03:28:14.013754Z","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-05-15T03:28:14.014409Z","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-05-15T03:28:14.014494Z","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-05-15T03:28:14.014564Z","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-05-15T03:28:14.014611Z","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-05-15T03:28:14.014661Z","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-05-15T03:28:14.014730Z","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-05-15T03:28:14.014781Z","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-05-15T03:28:14.014835Z","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-05-15T03:28:14.014880Z","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-05-15T03:28:14.015862Z","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-05-15T03:28:14.015938Z","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-05-15T03:28:14.015979Z","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-05-15T03:28:14.016017Z","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-05-15T03:28:14.016069Z","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-05-15T03:28:14.016109Z","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-05-15T03:28:14.018302Z","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-05-15T03:28:14.018393Z","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-05-15T03:28:14.019052Z","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-05-15T03:28:14.019104Z","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-05-15T03:28:14.019160Z","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-05-15T03:28:14.019200Z","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-05-15T03:28:13.982325Z","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_shutdown_during_job_retry_delay","threadId":"ThreadId(18)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.021577Z","level":"INFO","fields":{"message":"Shutdown signal received, waiting for 3s 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_signal_channel_closed","threadId":"ThreadId(19)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.021641Z","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_shutdown_during_job_retry_delay","threadId":"ThreadId(18)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.021912Z","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_shutdown_during_job_retry_delay","threadId":"ThreadId(18)"} [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.028452Z","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-05-15T03:28:14.029672Z","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-05-15T03:28:14.032829Z","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-05-15T03:28:14.032917Z","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-05-15T03:28:14.033046Z","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-05-15T03:28:14.036528Z","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-05-15T03:28:14.036618Z","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-05-15T03:28:14.036813Z","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-05-15T03:28:14.036966Z","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-05-15T03:28:14.037340Z","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-05-15T03:28:14.037567Z","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-05-15T03:28:14.040178Z","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-05-15T03:28:14.040250Z","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-05-15T03:28:14.040655Z","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-05-15T03:28:14.040747Z","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-05-15T03:28:14.040789Z","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-05-15T03:28:14.040821Z","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-05-15T03:28:14.059139Z","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-05-15T03:28:14.059263Z","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-05-15T03:28:14.059326Z","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-05-15T03:28:14.059413Z","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-05-15T03:28:14.059498Z","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-05-15T03:28:14.059559Z","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-05-15T03:28:14.061784Z","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-05-15T03:28:14.061874Z","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-05-15T03:28:14.062099Z","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-05-15T03:28:14.062286Z","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-05-15T03:28:14.062743Z","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-05-15T03:28:14.062809Z","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-05-15T03:28:14.065232Z","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-05-15T03:28:14.065301Z","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-05-15T03:28:14.065342Z","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-05-15T03:28:14.066553Z","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-05-15T03:28:14.066672Z","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-05-15T03:28:14.066759Z","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-05-15T03:28:14.066843Z","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-05-15T03:28:14.066934Z","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-05-15T03:28:14.067031Z","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-05-15T03:28:14.072997Z","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-05-15T03:28:14.076555Z","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-05-15T03:28:14.079860Z","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-05-15T03:28:14.080268Z","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-05-15T03:28:14.080381Z","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-05-15T03:28:14.080441Z","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-05-15T03:28:14.081171Z","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] {"timestamp":"2026-05-15T03:28:14.081251Z","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-05-15T03:28:14.081329Z","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-05-15T03:28:14.081405Z","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_job_retries_twice ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.081489Z","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-05-15T03:28:14.083688Z","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-05-15T03:28:14.083837Z","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-05-15T03:28:14.083969Z","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-05-15T03:28:14.084095Z","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-05-15T03:28:14.084646Z","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-05-15T03:28:14.084707Z","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-05-15T03:28:14.091978Z","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-05-15T03:28:14.092116Z","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-05-15T03:28:14.116565Z","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-05-15T03:28:14.116691Z","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-05-15T03:28:14.116755Z","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-05-15T03:28:14.118016Z","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-05-15T03:28:14.118077Z","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-05-15T03:28:14.118110Z","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-05-15T03:28:14.118152Z","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-05-15T03:28:14.122320Z","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] test test_concurrent_worker_shutdown_signal_channel_closed ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.163941Z","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-05-15T03:28:14.169529Z","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-05-15T03:28:14.169625Z","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-05-15T03:28:14.177996Z","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-05-15T03:28:14.181551Z","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-05-15T03:28:14.264107Z","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-05-15T03:28:14.275687Z","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-05-15T03:28:14.280524Z","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-05-15T03:28:14.463736Z","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-05-15T03:28:14.469645Z","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-05-15T03:28:14.476318Z","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-05-15T03:28:14.479454Z","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] {"timestamp":"2026-05-15T03:28:14.479581Z","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_multiple_jobs ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.479750Z","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_shutdown_with_empty_queue ... ok [INFO] [stdout] test test_concurrent_worker_job_succeeds_without_retries ... ok [INFO] [stdout] {"timestamp":"2026-05-15T03:28:14.484240Z","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-05-15T03:28:14.585800Z","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-05-15T03:28:14.595523Z","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-05-15T03:28:14.669999Z","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] [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.71s [INFO] [stdout] [INFO] [stderr] Running tests/concurrent_worker_integration.rs (/opt/rustwide/target/debug/deps/concurrent_worker_integration-6202b6fa09c2207b) [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_complete_workflow ... FAILED [INFO] [stdout] test test_queue_persistence ... FAILED [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] [INFO] [stdout] ---- test_concurrent_workers stdout ---- [INFO] [stdout] [INFO] [stdout] thread 'test_concurrent_workers' (46) 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: 0x5bd69066b62a - std[29689e6404d28ef9]::backtrace_rs::backtrace::libunwind::trace [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x5bd69066b62a - std[29689e6404d28ef9]::backtrace_rs::backtrace::trace_unsynchronized:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x5bd69066b62a - std[29689e6404d28ef9]::sys::backtrace::_print_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:74:9 [INFO] [stdout] 3: 0x5bd69066b62a - <::print::DisplayBacktrace as core[e929cb53b82a81ca]::fmt::Display>::fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:44:26 [INFO] [stdout] 4: 0x5bd690681e6a - ::fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/fmt/rt.rs:152:76 [INFO] [stdout] 5: 0x5bd690681e6a - core[e929cb53b82a81ca]::fmt::write [INFO] [stdout] 6: 0x5bd690670472 - std[29689e6404d28ef9]::io::default_write_fmt::> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/io/mod.rs:621:11 [INFO] [stdout] 7: 0x5bd690670472 - as std[29689e6404d28ef9]::io::Write>::write_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/io/mod.rs:1976:13 [INFO] [stdout] 8: 0x5bd690649adf - ::print [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:47:9 [INFO] [stdout] 9: 0x5bd690649adf - std[29689e6404d28ef9]::panicking::default_hook::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:292:27 [INFO] [stdout] 10: 0x5bd690663549 - std[29689e6404d28ef9]::panicking::default_hook [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:316:9 [INFO] [stdout] 11: 0x5bd69026556c - core[e929cb53b82a81ca]::ops::function::Fn<(&'a std[29689e6404d28ef9]::panic::PanicHookInfo<'b>,), Output = ()> + core[e929cb53b82a81ca]::marker::Send + core[e929cb53b82a81ca]::marker::Sync> as core[e929cb53b82a81ca]::ops::function::Fn<(&std[29689e6404d28ef9]::panic::PanicHookInfo,)>>::call [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2285:9 [INFO] [stdout] 12: 0x5bd69026556c - test[a24b3028667022f7]::test_main_inner::::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:155:21 [INFO] [stdout] 13: 0x5bd6906637c2 - core[e929cb53b82a81ca]::ops::function::Fn<(&'a std[29689e6404d28ef9]::panic::PanicHookInfo<'b>,), Output = ()> + core[e929cb53b82a81ca]::marker::Send + core[e929cb53b82a81ca]::marker::Sync> as core[e929cb53b82a81ca]::ops::function::Fn<(&std[29689e6404d28ef9]::panic::PanicHookInfo,)>>::call [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2285:9 [INFO] [stdout] 14: 0x5bd6906637c2 - std[29689e6404d28ef9]::panicking::panic_with_hook [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:833:13 [INFO] [stdout] 15: 0x5bd690649b98 - std[29689e6404d28ef9]::panicking::panic_handler::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:698:13 [INFO] [stdout] 16: 0x5bd69063ecc9 - std[29689e6404d28ef9]::sys::backtrace::__rust_end_short_backtrace:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:182:18 [INFO] [stdout] 17: 0x5bd69064aa6d - __rustc[3aed6af316653e63]::rust_begin_unwind [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:689:5 [INFO] [stdout] 18: 0x5bd6906826dc - core[e929cb53b82a81ca]::panicking::panic_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panicking.rs:80:14 [INFO] [stdout] 19: 0x5bd690682422 - core[e929cb53b82a81ca]::result::unwrap_failed [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/result.rs:1867:5 [INFO] [stdout] 20: 0x5bd690252945 - >::expect [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/result.rs:1185:23 [INFO] [stdout] 21: 0x5bd69020a39c - concurrent_worker_integration[a1988f2fc42c37c9]::test_concurrent_workers::{closure#0} [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:226:31 [INFO] [stdout] 22: 0x5bd69023a5a2 - > as core[e929cb53b82a81ca]::future::future::Future>::poll [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/future/future.rs:133:9 [INFO] [stdout] 23: 0x5bd69023a61d - >> as core[e929cb53b82a81ca]::future::future::Future>::poll [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/future/future.rs:133:9 [INFO] [stdout] 24: 0x5bd69021f43d - ::block_on::>>>::{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: 0x5bd69021f33b - tokio[4f4062f96bcf1d85]::task::coop::with_budget::, ::block_on>>>::{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: 0x5bd69021f33b - tokio[4f4062f96bcf1d85]::task::coop::budget::, ::block_on>>>::{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: 0x5bd69021f33b - ::block_on::>>>::{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: 0x5bd6902164d0 - ::enter::, ::block_on>>>::{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: 0x5bd69021d810 - ::block_on::>>>::{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: 0x5bd69021caf4 - ::enter::<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd69023b50b - >::set::<::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::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: 0x5bd6901d57d9 - tokio[4f4062f96bcf1d85]::runtime::context::set_scheduler::<(alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd6901db2c2 - >::try_with::, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>)> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/local.rs:462:12 [INFO] [stdout] 34: 0x5bd6901dae4e - >::with::, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>)> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/local.rs:426:20 [INFO] [stdout] 35: 0x5bd6901d222d - tokio[4f4062f96bcf1d85]::runtime::context::set_scheduler::<(alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd690219ad0 - ::enter::<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd690219dc6 - ::block_on::>>> [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: 0x5bd69021c603 - ::block_on::>>::{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: 0x5bd69023bf53 - tokio[4f4062f96bcf1d85]::runtime::context::runtime::enter_runtime::<::block_on>>::{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: 0x5bd690216001 - ::block_on::>> [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: 0x5bd6901da844 - ::block_on_inner::>> [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: 0x5bd6901daa0a - ::block_on::>> [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: 0x5bd69020cb61 - concurrent_worker_integration[a1988f2fc42c37c9]::test_concurrent_workers [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:264:35 [INFO] [stdout] 44: 0x5bd690205037 - concurrent_worker_integration[a1988f2fc42c37c9]::test_concurrent_workers::{closure#0} [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:209:35 [INFO] [stdout] 45: 0x5bd690214fd6 - >::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 46: 0x5bd69025884b - core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 47: 0x5bd69025884b - test[a24b3028667022f7]::__rust_begin_short_backtrace::, fn() -> core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:724:18 [INFO] [stdout] 48: 0x5bd69026603b - test[a24b3028667022f7]::run_test_in_process::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:747:74 [INFO] [stdout] 49: 0x5bd69026603b - as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panic/unwind_safe.rs:275:9 [INFO] [stdout] 50: 0x5bd69026603b - std[29689e6404d28ef9]::panicking::catch_unwind::do_call::, core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:581:40 [INFO] [stdout] 51: 0x5bd69026603b - std[29689e6404d28ef9]::panicking::catch_unwind::, core[e929cb53b82a81ca]::panic::unwind_safe::AssertUnwindSafe> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:544:19 [INFO] [stdout] 52: 0x5bd69026603b - std[29689e6404d28ef9]::panic::catch_unwind::, core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panic.rs:359:14 [INFO] [stdout] 53: 0x5bd69026603b - test[a24b3028667022f7]::run_test_in_process [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:747:27 [INFO] [stdout] 54: 0x5bd69026603b - test[a24b3028667022f7]::run_test::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:668:43 [INFO] [stdout] 55: 0x5bd69025f754 - test[a24b3028667022f7]::run_test::{closure#1} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:698:41 [INFO] [stdout] 56: 0x5bd69025f754 - std[29689e6404d28ef9]::sys::backtrace::__rust_begin_short_backtrace:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:166:18 [INFO] [stdout] 57: 0x5bd690268c42 - std[29689e6404d28ef9]::thread::lifecycle::spawn_unchecked::::{closure#1}::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/lifecycle.rs:70:13 [INFO] [stdout] 58: 0x5bd690268c42 - ::{closure#1}::{closure#0}> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panic/unwind_safe.rs:275:9 [INFO] [stdout] 59: 0x5bd690268c42 - std[29689e6404d28ef9]::panicking::catch_unwind::do_call::::{closure#1}::{closure#0}>, ()> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:581:40 [INFO] [stdout] 60: 0x5bd690268c42 - std[29689e6404d28ef9]::panicking::catch_unwind::<(), core[e929cb53b82a81ca]::panic::unwind_safe::AssertUnwindSafe::{closure#1}::{closure#0}>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:544:19 [INFO] [stdout] 61: 0x5bd690268c42 - std[29689e6404d28ef9]::panic::catch_unwind::::{closure#1}::{closure#0}>, ()> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panic.rs:359:14 [INFO] [stdout] 62: 0x5bd690268c42 - std[29689e6404d28ef9]::thread::lifecycle::spawn_unchecked::::{closure#1} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/lifecycle.rs:68:26 [INFO] [stdout] 63: 0x5bd690268c42 - ::{closure#1} as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 64: 0x5bd69066ad3f - + core[e929cb53b82a81ca]::marker::Send> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2271:9 [INFO] [stdout] 65: 0x5bd69066ad3f - ::new::thread_start [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/thread/unix.rs:118:17 [INFO] [stdout] 66: 0x7e9ca40f6aa4 - [INFO] [stdout] 67: 0x7e9ca4183a64 - clone [INFO] [stdout] 68: 0x0 - [INFO] [stdout] [INFO] [stdout] ---- test_complete_workflow stdout ---- [INFO] [stdout] [INFO] [stdout] thread 'test_complete_workflow' (45) 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: 0x5bd69066b62a - std[29689e6404d28ef9]::backtrace_rs::backtrace::libunwind::trace [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x5bd69066b62a - std[29689e6404d28ef9]::backtrace_rs::backtrace::trace_unsynchronized:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x5bd69066b62a - std[29689e6404d28ef9]::sys::backtrace::_print_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:74:9 [INFO] [stdout] 3: 0x5bd69066b62a - <::print::DisplayBacktrace as core[e929cb53b82a81ca]::fmt::Display>::fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:44:26 [INFO] [stdout] 4: 0x5bd690681e6a - ::fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/fmt/rt.rs:152:76 [INFO] [stdout] 5: 0x5bd690681e6a - core[e929cb53b82a81ca]::fmt::write [INFO] [stdout] 6: 0x5bd690670472 - std[29689e6404d28ef9]::io::default_write_fmt::> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/io/mod.rs:621:11 [INFO] [stdout] 7: 0x5bd690670472 - as std[29689e6404d28ef9]::io::Write>::write_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/io/mod.rs:1976:13 [INFO] [stdout] 8: 0x5bd690649adf - ::print [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:47:9 [INFO] [stdout] 9: 0x5bd690649adf - std[29689e6404d28ef9]::panicking::default_hook::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:292:27 [INFO] [stdout] 10: 0x5bd690663549 - std[29689e6404d28ef9]::panicking::default_hook [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:316:9 [INFO] [stdout] 11: 0x5bd69026556c - core[e929cb53b82a81ca]::ops::function::Fn<(&'a std[29689e6404d28ef9]::panic::PanicHookInfo<'b>,), Output = ()> + core[e929cb53b82a81ca]::marker::Send + core[e929cb53b82a81ca]::marker::Sync> as core[e929cb53b82a81ca]::ops::function::Fn<(&std[29689e6404d28ef9]::panic::PanicHookInfo,)>>::call [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2285:9 [INFO] [stdout] 12: 0x5bd69026556c - test[a24b3028667022f7]::test_main_inner::::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:155:21 [INFO] [stdout] 13: 0x5bd6906637c2 - core[e929cb53b82a81ca]::ops::function::Fn<(&'a std[29689e6404d28ef9]::panic::PanicHookInfo<'b>,), Output = ()> + core[e929cb53b82a81ca]::marker::Send + core[e929cb53b82a81ca]::marker::Sync> as core[e929cb53b82a81ca]::ops::function::Fn<(&std[29689e6404d28ef9]::panic::PanicHookInfo,)>>::call [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2285:9 [INFO] [stdout] 14: 0x5bd6906637c2 - std[29689e6404d28ef9]::panicking::panic_with_hook [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:833:13 [INFO] [stdout] 15: 0x5bd690649b98 - std[29689e6404d28ef9]::panicking::panic_handler::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:698:13 [INFO] [stdout] 16: 0x5bd69063ecc9 - std[29689e6404d28ef9]::sys::backtrace::__rust_end_short_backtrace:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:182:18 [INFO] [stdout] 17: 0x5bd69064aa6d - __rustc[3aed6af316653e63]::rust_begin_unwind [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:689:5 [INFO] [stdout] 18: 0x5bd6906826dc - core[e929cb53b82a81ca]::panicking::panic_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panicking.rs:80:14 [INFO] [stdout] 19: 0x5bd690682422 - core[e929cb53b82a81ca]::result::unwrap_failed [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/result.rs:1867:5 [INFO] [stdout] 20: 0x5bd690252945 - >::expect [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/result.rs:1185:23 [INFO] [stdout] 21: 0x5bd690206aeb - concurrent_worker_integration[a1988f2fc42c37c9]::test_complete_workflow::{closure#0} [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:155:10 [INFO] [stdout] 22: 0x5bd69023a5a2 - > as core[e929cb53b82a81ca]::future::future::Future>::poll [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/future/future.rs:133:9 [INFO] [stdout] 23: 0x5bd69023a61d - >> as core[e929cb53b82a81ca]::future::future::Future>::poll [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/future/future.rs:133:9 [INFO] [stdout] 24: 0x5bd69021f43d - ::block_on::>>>::{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: 0x5bd69021f33b - tokio[4f4062f96bcf1d85]::task::coop::with_budget::, ::block_on>>>::{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: 0x5bd69021f33b - tokio[4f4062f96bcf1d85]::task::coop::budget::, ::block_on>>>::{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: 0x5bd69021f33b - ::block_on::>>>::{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: 0x5bd6902164d0 - ::enter::, ::block_on>>>::{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: 0x5bd69021d810 - ::block_on::>>>::{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: 0x5bd69021caf4 - ::enter::<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd69023b50b - >::set::<::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::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: 0x5bd6901d57d9 - tokio[4f4062f96bcf1d85]::runtime::context::set_scheduler::<(alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd6901db2c2 - >::try_with::, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>)> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/local.rs:462:12 [INFO] [stdout] 34: 0x5bd6901dae4e - >::with::, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>)> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/local.rs:426:20 [INFO] [stdout] 35: 0x5bd6901d222d - tokio[4f4062f96bcf1d85]::runtime::context::set_scheduler::<(alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd690219ad0 - ::enter::<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd690219dc6 - ::block_on::>>> [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: 0x5bd69021c603 - ::block_on::>>::{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: 0x5bd69023bf53 - tokio[4f4062f96bcf1d85]::runtime::context::runtime::enter_runtime::<::block_on>>::{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: 0x5bd690216001 - ::block_on::>> [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: 0x5bd6901da844 - ::block_on_inner::>> [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: 0x5bd6901daa0a - ::block_on::>> [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: 0x5bd69020c7e1 - concurrent_worker_integration[a1988f2fc42c37c9]::test_complete_workflow [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:205:45 [INFO] [stdout] 44: 0x5bd690204fd7 - concurrent_worker_integration[a1988f2fc42c37c9]::test_complete_workflow::{closure#0} [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:121:34 [INFO] [stdout] 45: 0x5bd690214f56 - >::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 46: 0x5bd69025884b - core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 47: 0x5bd69025884b - test[a24b3028667022f7]::__rust_begin_short_backtrace::, fn() -> core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:724:18 [INFO] [stdout] 48: 0x5bd69026603b - test[a24b3028667022f7]::run_test_in_process::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:747:74 [INFO] [stdout] 49: 0x5bd69026603b - as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panic/unwind_safe.rs:275:9 [INFO] [stdout] 50: 0x5bd69026603b - std[29689e6404d28ef9]::panicking::catch_unwind::do_call::, core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:581:40 [INFO] [stdout] 51: 0x5bd69026603b - std[29689e6404d28ef9]::panicking::catch_unwind::, core[e929cb53b82a81ca]::panic::unwind_safe::AssertUnwindSafe> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:544:19 [INFO] [stdout] 52: 0x5bd69026603b - std[29689e6404d28ef9]::panic::catch_unwind::, core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panic.rs:359:14 [INFO] [stdout] 53: 0x5bd69026603b - test[a24b3028667022f7]::run_test_in_process [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:747:27 [INFO] [stdout] 54: 0x5bd69026603b - test[a24b3028667022f7]::run_test::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:668:43 [INFO] [stdout] 55: 0x5bd69025f754 - test[a24b3028667022f7]::run_test::{closure#1} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:698:41 [INFO] [stdout] 56: 0x5bd69025f754 - std[29689e6404d28ef9]::sys::backtrace::__rust_begin_short_backtrace:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:166:18 [INFO] [stdout] 57: 0x5bd690268c42 - std[29689e6404d28ef9]::thread::lifecycle::spawn_unchecked::::{closure#1}::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/lifecycle.rs:70:13 [INFO] [stdout] 58: 0x5bd690268c42 - ::{closure#1}::{closure#0}> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panic/unwind_safe.rs:275:9 [INFO] [stdout] 59: 0x5bd690268c42 - std[29689e6404d28ef9]::panicking::catch_unwind::do_call::::{closure#1}::{closure#0}>, ()> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:581:40 [INFO] [stdout] 60: 0x5bd690268c42 - std[29689e6404d28ef9]::panicking::catch_unwind::<(), core[e929cb53b82a81ca]::panic::unwind_safe::AssertUnwindSafe::{closure#1}::{closure#0}>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:544:19 [INFO] [stdout] 61: 0x5bd690268c42 - std[29689e6404d28ef9]::panic::catch_unwind::::{closure#1}::{closure#0}>, ()> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panic.rs:359:14 [INFO] [stdout] 62: 0x5bd690268c42 - std[29689e6404d28ef9]::thread::lifecycle::spawn_unchecked::::{closure#1} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/lifecycle.rs:68:26 [INFO] [stdout] 63: 0x5bd690268c42 - ::{closure#1} as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 64: 0x5bd69066ad3f - + core[e929cb53b82a81ca]::marker::Send> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2271:9 [INFO] [stdout] 65: 0x5bd69066ad3f - ::new::thread_start [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/thread/unix.rs:118:17 [INFO] [stdout] 66: 0x7e9ca40f6aa4 - [INFO] [stdout] 67: 0x7e9ca4183a64 - clone [INFO] [stdout] 68: 0x0 - [INFO] [stdout] [INFO] [stdout] ---- test_queue_persistence stdout ---- [INFO] [stdout] [INFO] [stdout] thread 'test_queue_persistence' (47) 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: 0x5bd69066b62a - std[29689e6404d28ef9]::backtrace_rs::backtrace::libunwind::trace [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x5bd69066b62a - std[29689e6404d28ef9]::backtrace_rs::backtrace::trace_unsynchronized:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x5bd69066b62a - std[29689e6404d28ef9]::sys::backtrace::_print_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:74:9 [INFO] [stdout] 3: 0x5bd69066b62a - <::print::DisplayBacktrace as core[e929cb53b82a81ca]::fmt::Display>::fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:44:26 [INFO] [stdout] 4: 0x5bd690681e6a - ::fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/fmt/rt.rs:152:76 [INFO] [stdout] 5: 0x5bd690681e6a - core[e929cb53b82a81ca]::fmt::write [INFO] [stdout] 6: 0x5bd690670472 - std[29689e6404d28ef9]::io::default_write_fmt::> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/io/mod.rs:621:11 [INFO] [stdout] 7: 0x5bd690670472 - as std[29689e6404d28ef9]::io::Write>::write_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/io/mod.rs:1976:13 [INFO] [stdout] 8: 0x5bd690649adf - ::print [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:47:9 [INFO] [stdout] 9: 0x5bd690649adf - std[29689e6404d28ef9]::panicking::default_hook::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:292:27 [INFO] [stdout] 10: 0x5bd690663549 - std[29689e6404d28ef9]::panicking::default_hook [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:316:9 [INFO] [stdout] 11: 0x5bd69026556c - core[e929cb53b82a81ca]::ops::function::Fn<(&'a std[29689e6404d28ef9]::panic::PanicHookInfo<'b>,), Output = ()> + core[e929cb53b82a81ca]::marker::Send + core[e929cb53b82a81ca]::marker::Sync> as core[e929cb53b82a81ca]::ops::function::Fn<(&std[29689e6404d28ef9]::panic::PanicHookInfo,)>>::call [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2285:9 [INFO] [stdout] 12: 0x5bd69026556c - test[a24b3028667022f7]::test_main_inner::::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:155:21 [INFO] [stdout] 13: 0x5bd6906637c2 - core[e929cb53b82a81ca]::ops::function::Fn<(&'a std[29689e6404d28ef9]::panic::PanicHookInfo<'b>,), Output = ()> + core[e929cb53b82a81ca]::marker::Send + core[e929cb53b82a81ca]::marker::Sync> as core[e929cb53b82a81ca]::ops::function::Fn<(&std[29689e6404d28ef9]::panic::PanicHookInfo,)>>::call [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2285:9 [INFO] [stdout] 14: 0x5bd6906637c2 - std[29689e6404d28ef9]::panicking::panic_with_hook [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:833:13 [INFO] [stdout] 15: 0x5bd690649b98 - std[29689e6404d28ef9]::panicking::panic_handler::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:698:13 [INFO] [stdout] 16: 0x5bd69063ecc9 - std[29689e6404d28ef9]::sys::backtrace::__rust_end_short_backtrace:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:182:18 [INFO] [stdout] 17: 0x5bd69064aa6d - __rustc[3aed6af316653e63]::rust_begin_unwind [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:689:5 [INFO] [stdout] 18: 0x5bd6906826dc - core[e929cb53b82a81ca]::panicking::panic_fmt [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panicking.rs:80:14 [INFO] [stdout] 19: 0x5bd690682422 - core[e929cb53b82a81ca]::result::unwrap_failed [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/result.rs:1867:5 [INFO] [stdout] 20: 0x5bd690252945 - >::expect [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/result.rs:1185:23 [INFO] [stdout] 21: 0x5bd6902088a7 - concurrent_worker_integration[a1988f2fc42c37c9]::test_queue_persistence::{closure#0} [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:284:35 [INFO] [stdout] 22: 0x5bd69023a5a2 - > as core[e929cb53b82a81ca]::future::future::Future>::poll [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/future/future.rs:133:9 [INFO] [stdout] 23: 0x5bd69023a61d - >> as core[e929cb53b82a81ca]::future::future::Future>::poll [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/future/future.rs:133:9 [INFO] [stdout] 24: 0x5bd69021f43d - ::block_on::>>>::{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: 0x5bd69021f33b - tokio[4f4062f96bcf1d85]::task::coop::with_budget::, ::block_on>>>::{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: 0x5bd69021f33b - tokio[4f4062f96bcf1d85]::task::coop::budget::, ::block_on>>>::{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: 0x5bd69021f33b - ::block_on::>>>::{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: 0x5bd6902164d0 - ::enter::, ::block_on>>>::{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: 0x5bd69021d810 - ::block_on::>>>::{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: 0x5bd69021caf4 - ::enter::<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd69023b50b - >::set::<::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::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: 0x5bd6901d57d9 - tokio[4f4062f96bcf1d85]::runtime::context::set_scheduler::<(alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd6901db2c2 - >::try_with::, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>)> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/local.rs:462:12 [INFO] [stdout] 34: 0x5bd6901dae4e - >::with::, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::option::Option<()>>::{closure#0}>::{closure#0}, (alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>)> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/local.rs:426:20 [INFO] [stdout] 35: 0x5bd6901d222d - tokio[4f4062f96bcf1d85]::runtime::context::set_scheduler::<(alloc[9d7caffeb3b5d2c6]::boxed::Box, core[e929cb53b82a81ca]::option::Option<()>), ::enter<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd690219ad0 - ::enter::<::block_on>>>::{closure#0}, core[e929cb53b82a81ca]::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: 0x5bd690219dc6 - ::block_on::>>> [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: 0x5bd69021c603 - ::block_on::>>::{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: 0x5bd69023bf53 - tokio[4f4062f96bcf1d85]::runtime::context::runtime::enter_runtime::<::block_on>>::{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] [stderr] error: test failed, to rerun pass `--test concurrent_worker_integration` [INFO] [stdout] 40: 0x5bd690216001 - ::block_on::>> [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: 0x5bd6901da844 - ::block_on_inner::>> [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: 0x5bd6901daa0a - ::block_on::>> [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: 0x5bd69020c9a1 - concurrent_worker_integration[a1988f2fc42c37c9]::test_queue_persistence [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:293:45 [INFO] [stdout] 44: 0x5bd690205007 - concurrent_worker_integration[a1988f2fc42c37c9]::test_queue_persistence::{closure#0} [INFO] [stdout] at /opt/rustwide/workdir/tests/concurrent_worker_integration.rs:271:34 [INFO] [stdout] 45: 0x5bd690214f96 - >::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 46: 0x5bd69025884b - core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 47: 0x5bd69025884b - test[a24b3028667022f7]::__rust_begin_short_backtrace::, fn() -> core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:724:18 [INFO] [stdout] 48: 0x5bd69026603b - test[a24b3028667022f7]::run_test_in_process::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:747:74 [INFO] [stdout] 49: 0x5bd69026603b - as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panic/unwind_safe.rs:275:9 [INFO] [stdout] 50: 0x5bd69026603b - std[29689e6404d28ef9]::panicking::catch_unwind::do_call::, core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:581:40 [INFO] [stdout] 51: 0x5bd69026603b - std[29689e6404d28ef9]::panicking::catch_unwind::, core[e929cb53b82a81ca]::panic::unwind_safe::AssertUnwindSafe> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:544:19 [INFO] [stdout] 52: 0x5bd69026603b - std[29689e6404d28ef9]::panic::catch_unwind::, core[e929cb53b82a81ca]::result::Result<(), alloc[9d7caffeb3b5d2c6]::string::String>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panic.rs:359:14 [INFO] [stdout] 53: 0x5bd69026603b - test[a24b3028667022f7]::run_test_in_process [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:747:27 [INFO] [stdout] 54: 0x5bd69026603b - test[a24b3028667022f7]::run_test::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:668:43 [INFO] [stdout] 55: 0x5bd69025f754 - test[a24b3028667022f7]::run_test::{closure#1} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/test/src/lib.rs:698:41 [INFO] [stdout] 56: 0x5bd69025f754 - std[29689e6404d28ef9]::sys::backtrace::__rust_begin_short_backtrace:: [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/backtrace.rs:166:18 [INFO] [stdout] 57: 0x5bd690268c42 - std[29689e6404d28ef9]::thread::lifecycle::spawn_unchecked::::{closure#1}::{closure#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/lifecycle.rs:70:13 [INFO] [stdout] 58: 0x5bd690268c42 - ::{closure#1}::{closure#0}> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/panic/unwind_safe.rs:275:9 [INFO] [stdout] 59: 0x5bd690268c42 - std[29689e6404d28ef9]::panicking::catch_unwind::do_call::::{closure#1}::{closure#0}>, ()> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:581:40 [INFO] [stdout] 60: 0x5bd690268c42 - std[29689e6404d28ef9]::panicking::catch_unwind::<(), core[e929cb53b82a81ca]::panic::unwind_safe::AssertUnwindSafe::{closure#1}::{closure#0}>> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panicking.rs:544:19 [INFO] [stdout] 61: 0x5bd690268c42 - std[29689e6404d28ef9]::panic::catch_unwind::::{closure#1}::{closure#0}>, ()> [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/panic.rs:359:14 [INFO] [stdout] 62: 0x5bd690268c42 - std[29689e6404d28ef9]::thread::lifecycle::spawn_unchecked::::{closure#1} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/thread/lifecycle.rs:68:26 [INFO] [stdout] 63: 0x5bd690268c42 - ::{closure#1} as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0} [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 64: 0x5bd69066ad3f - + core[e929cb53b82a81ca]::marker::Send> as core[e929cb53b82a81ca]::ops::function::FnOnce<()>>::call_once [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/alloc/src/boxed.rs:2271:9 [INFO] [stdout] 65: 0x5bd69066ad3f - ::new::thread_start [INFO] [stdout] at /rustc/ec6f9a5b4413f74386267ef8efc93712c2ce6db6/library/std/src/sys/thread/unix.rs:118:17 [INFO] [stdout] 66: 0x7e9ca40f6aa4 - [INFO] [stdout] 67: 0x7e9ca4183a64 - clone [INFO] [stdout] 68: 0x0 - [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.05s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "6289cb6e9047009af23067b56fe11ad71afcade6f1893cada7987af6b128417e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "6289cb6e9047009af23067b56fe11ad71afcade6f1893cada7987af6b128417e", kill_on_drop: false }` [INFO] [stdout] 6289cb6e9047009af23067b56fe11ad71afcade6f1893cada7987af6b128417e