[INFO] fetching crate drasi-reaction-file 0.1.6...
[INFO] testing drasi-reaction-file-0.1.6 against 1.100.0-beta.1 for beta-1.100-2
[INFO] extracting crate drasi-reaction-file 0.1.6 into /workspace/builds/worker-5-tc2/source
[INFO] started tweaking crates.io crate drasi-reaction-file 0.1.6
[INFO] removed 0 missing tests
[INFO] finished tweaking crates.io crate drasi-reaction-file 0.1.6
[INFO] tweaked toml for crates.io crate drasi-reaction-file 0.1.6 written to /workspace/builds/worker-5-tc2/source/Cargo.toml
[INFO] validating manifest of crates.io crate drasi-reaction-file 0.1.6 on toolchain 1.100.0-beta.1
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.100.0-beta.1" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate drasi-reaction-file 0.1.6 already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.100.0-beta.1" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:3111399a4047eeb3a02b7a90e478d715f38a8c6669b5c4b49d30a17385265909" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] 6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447
[INFO] running `Command { std: "docker" "start" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447" "/opt/rustwide/cargo-home/bin/cargo" "+1.100.0-beta.1" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447" "/opt/rustwide/cargo-home/bin/cargo" "+1.100.0-beta.1" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.107
[INFO] [stderr]    Compiling unicode-ident v1.0.26
[INFO] [stderr]    Compiling quote v1.0.47
[INFO] [stderr]    Compiling autocfg v1.5.1
[INFO] [stderr]    Compiling libc v0.2.189
[INFO] [stderr]    Compiling memchr v2.8.3
[INFO] [stderr]    Compiling serde_core v1.0.229
[INFO] [stderr]    Compiling cfg-if v1.0.5
[INFO] [stderr]    Compiling serde v1.0.229
[INFO] [stderr]    Compiling rand_core v0.4.3
[INFO] [stderr]    Compiling futures-core v0.3.34
[INFO] [stderr]    Compiling zerocopy v0.8.59
[INFO] [stderr]    Compiling autocfg v0.1.8
[INFO] [stderr]    Compiling futures-sink v0.3.34
[INFO] [stderr]    Compiling rand_core v0.3.2
[INFO] [stderr]    Compiling futures-channel v0.3.34
[INFO] [stderr]    Compiling anyhow v1.0.104
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]    Compiling indexmap v1.9.3
[INFO] [stderr]    Compiling futures-task v0.3.34
[INFO] [stderr]    Compiling futures-io v0.3.34
[INFO] [stderr]    Compiling aho-corasick v1.1.5
[INFO] [stderr]    Compiling syn v3.0.6
[INFO] [stderr]    Compiling syn v2.0.119
[INFO] [stderr]    Compiling num-bigint v0.2.6
[INFO] [stderr]    Compiling regex-syntax v0.8.11
[INFO] [stderr]    Compiling getrandom v0.2.17
[INFO] [stderr]    Compiling num-integer v0.1.47
[INFO] [stderr]    Compiling rand_core v0.6.4
[INFO] [stderr]    Compiling hashbrown v0.12.3
[INFO] [stderr]    Compiling smallvec v1.16.2
[INFO] [stderr]    Compiling crossbeam-utils v0.8.23
[INFO] [stderr]    Compiling num-rational v0.2.4
[INFO] [stderr]    Compiling rand_pcg v0.1.2
[INFO] [stderr]    Compiling num-complex v0.2.4
[INFO] [stderr]    Compiling rand_chacha v0.1.1
[INFO] [stderr]    Compiling bytes v1.12.1
[INFO] [stderr]    Compiling peg-runtime v0.8.6
[INFO] [stderr]    Compiling radium v0.7.0
[INFO] [stderr]    Compiling serde_json v1.0.151
[INFO] [stderr]    Compiling regex-automata v0.4.18
[INFO] [stderr]    Compiling peg-macros v0.8.6
[INFO] [stderr]    Compiling parking_lot_core v0.9.12
[INFO] [stderr]    Compiling errno v0.3.14
[INFO] [stderr]    Compiling rand v0.6.5
[INFO] [stderr]    Compiling log v0.4.34
[INFO] [stderr]    Compiling getrandom v0.4.3
[INFO] [stderr]    Compiling siphasher v1.0.4
[INFO] [stderr]    Compiling urlencoding v2.1.3
[INFO] [stderr]    Compiling tap v1.0.1
[INFO] [stderr]    Compiling ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling wyz v0.5.1
[INFO] [stderr]    Compiling peg v0.8.6
[INFO] [stderr]    Compiling phf_shared v0.12.1
[INFO] [stderr]    Compiling crossbeam-channel v0.5.17
[INFO] [stderr]    Compiling signal-hook-registry v1.4.8
[INFO] [stderr]    Compiling parking_lot v0.12.5
[INFO] [stderr]    Compiling rand_chacha v0.3.1
[INFO] [stderr]    Compiling rand v0.8.8
[INFO] [stderr]    Compiling serde_derive v1.0.229
[INFO] [stderr]    Compiling futures-macro v0.3.34
[INFO] [stderr]    Compiling async-trait v0.1.92
[INFO] [stderr]    Compiling tokio-macros v2.7.2
[INFO] [stderr]    Compiling num-iter v0.1.46
[INFO] [stderr]    Compiling futures-util v0.3.34
[INFO] [stderr]    Compiling rand_os v0.1.3
[INFO] [stderr]    Compiling socket2 v0.6.5
[INFO] [stderr]    Compiling mio v1.2.3
[INFO] [stderr]    Compiling priority-queue v1.4.0
[INFO] [stderr]    Compiling rand_isaac v0.1.1
[INFO] [stderr]    Compiling rand_xorshift v0.1.1
[INFO] [stderr]    Compiling thiserror-impl v1.0.69
[INFO] [stderr]    Compiling tracing-attributes v0.1.31
[INFO] [stderr]    Compiling rand_hc v0.1.0
[INFO] [stderr]    Compiling rand_jitter v0.1.4
[INFO] [stderr]    Compiling funty v2.0.0
[INFO] [stderr]    Compiling time-core v0.1.9
[INFO] [stderr]    Compiling num-conv v0.2.2
[INFO] [stderr]    Compiling chrono-tz v0.10.4
[INFO] [stderr]    Compiling nom v7.1.3
[INFO] [stderr]    Compiling time-macros v0.2.32
[INFO] [stderr]    Compiling bitvec v1.1.1
[INFO] [stderr]    Compiling thiserror v1.0.69
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling regex v1.13.1
[INFO] [stderr]    Compiling fxhash v0.2.1
[INFO] [stderr]    Compiling tokio v1.53.1
[INFO] [stderr]    Compiling async-stream-impl v0.3.6
[INFO] [stderr]    Compiling num v0.2.1
[INFO] [stderr]    Compiling phf v0.12.1
[INFO] [stderr]    Compiling deranged v0.5.8
[INFO] [stderr]    Compiling proc-macro-error-attr v1.0.4
[INFO] [stderr]    Compiling syn v1.0.109
[INFO] [stderr]    Compiling hashbrown v0.17.1
[INFO] [stderr]    Compiling async-stream v0.3.6
[INFO] [stderr]    Compiling futures-executor v0.3.34
[INFO] [stderr]    Compiling drasi-query-ast v0.3.5
[INFO] [stderr]    Compiling ordered-float v3.9.2
[INFO] [stderr]    Compiling chrono v0.4.45
[INFO] [stderr]    Compiling opentelemetry_api v0.20.0
[INFO] [stderr]    Compiling drasi-query-cypher v0.3.6
[INFO] [stderr]    Compiling indexmap v2.14.2
[INFO] [stderr]    Compiling caches v0.2.8
[INFO] [stderr]    Compiling opentelemetry_sdk v0.20.0
[INFO] [stderr]    Compiling time v0.3.55
[INFO] [stderr]    Compiling futures v0.3.34
[INFO] [stderr]    Compiling uuid v1.26.1
[INFO] [stderr]    Compiling statistical v1.0.0
[INFO] [stderr]    Compiling iso8601-duration v0.2.0
[INFO] [stderr]    Compiling opentelemetry v0.20.0
[INFO] [stderr]    Compiling dateparser v0.2.1
[INFO] [stderr]    Compiling hashers v1.0.1
[INFO] [stderr]    Compiling async-recursion v1.1.1
[INFO] [stderr]    Compiling approx v0.5.1
[INFO] [stderr]    Compiling proc-macro-error v1.0.4
[INFO] [stderr]    Compiling typenum v1.20.1
[INFO] [stderr]    Compiling round v0.1.2
[INFO] [stderr]    Compiling ucd-trie v0.1.7
[INFO] [stderr]    Compiling pest v2.9.2
[INFO] [stderr]    Compiling im v15.1.0
[INFO] [stderr]    Compiling bitmaps v2.1.0
[INFO] [stderr]    Compiling either v1.18.0
[INFO] [stderr]    Compiling thiserror v2.0.21
[INFO] [stderr]    Compiling itertools v0.12.1
[INFO] [stderr]    Compiling matchers v0.2.0
[INFO] [stderr]    Compiling thiserror-impl v2.0.21
[INFO] [stderr]    Compiling pest_meta v2.9.2
[INFO] [stderr]    Compiling sized-chunks v0.6.5
[INFO] [stderr]    Compiling tracing-log v0.2.0
[INFO] [stderr]    Compiling rand_xoshiro v0.6.0
[INFO] [stderr]    Compiling rmp v0.8.15
[INFO] [stderr]    Compiling tokio-stream v0.1.19
[INFO] [stderr]    Compiling thread_local v1.1.10
[INFO] [stderr]    Compiling fixedbitset v0.4.2
[INFO] [stderr]    Compiling unsafe-libyaml v0.2.11
[INFO] [stderr]    Compiling tracing-subscriber v0.3.23
[INFO] [stderr]    Compiling drasi-plugin-sdk v0.11.3
[INFO] [stderr]    Compiling petgraph v0.6.5
[INFO] [stderr]    Compiling prost-derive v0.12.6
[INFO] [stderr]    Compiling pest_generator v2.9.2
[INFO] [stderr]    Compiling serde_yaml v0.9.34+deprecated
[INFO] [stderr]    Compiling rmp-serde v1.3.1
[INFO] [stderr]    Compiling utoipa-gen v4.3.1
[INFO] [stderr]    Compiling drasi-query-gql v0.3.6
[INFO] [stderr]    Compiling bincode v1.3.3
[INFO] [stderr]    Compiling prost v0.12.6
[INFO] [stderr]    Compiling pest_derive v2.9.2
[INFO] [stderr]    Compiling drasi-ffi-primitives v0.11.3
[INFO] [stderr]    Compiling prost-types v0.12.6
[INFO] [stderr]    Compiling handlebars v5.1.2
[INFO] [stderr]    Compiling drasi-core v0.5.10
[INFO] [stderr]    Compiling utoipa v4.2.3
[INFO] [stderr]    Compiling drasi-functions-cypher v0.5.10
[INFO] [stderr]    Compiling drasi-functions-gql v0.5.10
[INFO] [stderr]    Compiling drasi-lib v0.9.3
[INFO] [stderr]    Compiling drasi-reaction-file v0.1.6 (/opt/rustwide/workdir)
[INFO] [stderr] warning: unused dependency `prost-types`
[INFO] [stderr]   --> Cargo.toml:28:15
[INFO] [stderr]    |
[INFO] [stderr] 28 | [dependencies.prost-types]
[INFO] [stderr]    |               ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `cargo::unused_dependencies` is set to `warn` by default
[INFO] [stderr] help: consider removing the dependency on `prost-types`
[INFO] [stderr] warning: `drasi-reaction-file` (manifest) generated 1 warning
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 3m 08s
[INFO] running `Command { std: "docker" "inspect" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447" "/opt/rustwide/cargo-home/bin/cargo" "+1.100.0-beta.1" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling tokio v1.53.1
[INFO] [stderr]    Compiling rustix v1.1.5
[INFO] [stderr]    Compiling bitflags v2.13.2
[INFO] [stderr]    Compiling fastrand v2.5.0
[INFO] [stderr]    Compiling tempfile v3.27.0
[INFO] [stderr]    Compiling tokio-stream v0.1.19
[INFO] [stderr]    Compiling drasi-core v0.5.10
[INFO] [stderr]    Compiling tokio-test v0.4.6
[INFO] [stderr]    Compiling drasi-functions-gql v0.5.10
[INFO] [stderr]    Compiling drasi-functions-cypher v0.5.10
[INFO] [stderr]    Compiling drasi-lib v0.9.3
[INFO] [stderr]    Compiling drasi-plugin-sdk v0.11.3
[INFO] [stderr]    Compiling drasi-source-application v0.2.11
[INFO] [stderr]    Compiling drasi-reaction-file v0.1.6 (/opt/rustwide/workdir)
[INFO] [stderr] warning: unused dependency `prost-types`
[INFO] [stderr]   --> Cargo.toml:28:15
[INFO] [stderr]    |
[INFO] [stderr] 28 | [dependencies.prost-types]
[INFO] [stderr]    |               ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `cargo::unused_dependencies` is set to `warn` by default
[INFO] [stderr] help: consider removing the dependency on `prost-types`
[INFO] [stderr] warning: `drasi-reaction-file` (manifest) generated 1 warning
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 1m 08s
[INFO] running `Command { std: "docker" "inspect" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-w" "/opt/rustwide/workdir" "--user" "0:0" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447" "/opt/rustwide/cargo-home/bin/cargo" "+1.100.0-beta.1" "test" "--frozen", kill_on_drop: false }`
[INFO] [stderr] warning: unused dependency `prost-types`
[INFO] [stderr]   --> Cargo.toml:28:15
[INFO] [stderr]    |
[INFO] [stderr] 28 | [dependencies.prost-types]
[INFO] [stderr]    |               ^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `cargo::unused_dependencies` is set to `warn` by default
[INFO] [stderr] help: consider removing the dependency on `prost-types`
[INFO] [stderr] warning: `drasi-reaction-file` (manifest) generated 1 warning
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.41s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/build/drasi-reaction-file/0ebf9c864dc9af41/out/drasi_reaction_file-0ebf9c864dc9af41)
[INFO] [stdout] 
[INFO] [stdout] running 25 tests
[INFO] [stdout] test file::tests::test_empty_output_path_fails_build ... ok
[INFO] [stdout] test descriptor::tests::test_write_mode_dto_roundtrip ... ok
[INFO] [stdout] test file::tests::test_invalid_route_fails_build ... ok
[INFO] [stdout] test file::tests::test_invalid_label_template_fails_build ... ok
[INFO] [stdout] test file::tests::test_invalid_template_fails_build ... ok
[INFO] [stdout] test descriptor::tests::test_full_config_dto_roundtrip ... ok
[INFO] [stdout] test descriptor::tests::test_query_config_dto_to_domain ... ok
[INFO] [stdout] test descriptor::tests::test_create_reaction_from_config_json ... ok
[INFO] [stdout] test descriptor::tests::test_template_spec_dto_to_domain ... ok
[INFO] [stdout] test file::tests::test_render_output_update ... ok
[INFO] [stdout] test file::tests::test_render_output_delete ... ok
[INFO] [stdout] test file::tests::test_render_output_aggregation ... ok
[INFO] [stdout] test file::tests::test_default_template_route_lookup ... ok
[INFO] [stdout] test file::tests::test_query_route_overrides_default ... ok
[INFO] [stdout] test file::tests::test_repair_partial_line_entire_file_is_partial ... ok
[INFO] [stdout] test file::tests::test_repair_append_file_once_only_repairs_first_time ... ok
[INFO] [stdout] test file::tests::test_sanitize_filename ... ok
[INFO] [stdout] test file::tests::test_sanitize_filename_control_chars ... ok
[INFO] [stdout] test file::tests::test_sanitize_filename_reserved_windows_names ... ok
[INFO] [stdout] test file::tests::test_query_route_no_match_falls_to_default ... ok
[INFO] [stdout] test file::tests::test_fallback_to_raw_json_when_no_template ... ok
[INFO] [stdout] test file::tests::test_payload_filename_template_and_sanitization ... ok
[INFO] [stdout] test file::tests::test_repair_partial_line_no_op_when_file_ends_with_newline ... ok
[INFO] [stdout] test file::tests::test_repair_partial_line_empty_file_is_no_op ... ok
[INFO] [stdout] test file::tests::test_repair_partial_line_truncates_incomplete_trailing_content ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 25 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.03s
[INFO] [stdout] 
[INFO] [stderr]      Running tests/integration_test.rs (/opt/rustwide/target/debug/build/drasi-reaction-file/ddc4ed9c18a4adf0/out/integration_test-ddc4ed9c18a4adf0)
[INFO] [stdout] 
[INFO] [stdout] running 7 tests
[INFO] [stdout] [2m2026-10-06T15:41:39.370869Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.371007Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.371024Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.371042Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.371494Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.371539Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.371557Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.371571Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.371599Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.371703Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.371703Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.371723Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.371730Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.371743Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.371745Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.371757Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.371787Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.371825Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.371884Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.371904Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.371938Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.372094Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.372094Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.372112Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.372114Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.372129Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.372135Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.372141Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.372200Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.372271Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.372296Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.372308Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.372321Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.372342Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.372369Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.372410Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.372427Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.372464Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.372544Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.372655Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.372676Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.372694Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.373000Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.373018Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.373032Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.373042Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.373148Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.373168Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.373178Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.373190Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.373216Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.373239Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.373278Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.373293Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.373314Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.373403Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.373416Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.373435Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.373491Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.373736Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.373953Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.377592Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.378606Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.379155Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.382574Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.383026Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.383469Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.374126Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.380193Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.378561Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.385364Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.385745Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.386450Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.387299Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.387991Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.388346Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.387846Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'test-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.387960Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.389499Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.389952Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.390377Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.390867Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.391432Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.386248Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.395078Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.395481Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.396055Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.396076Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.396093Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.396105Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.396259Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.396290Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.396305Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.396319Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.396353Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.396391Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.396479Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.396500Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.396558Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.396713Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.396730Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.396755Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.396829Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.397478Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.397542Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'test-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.397586Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.397655Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.397742Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.397766Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.397796Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.397834Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.397982Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.398003Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.398200Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.398315Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.398358Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.398407Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.400580Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.400668Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.400768Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.400931Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.400995Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'test-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.401011Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.401029Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.401031Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.401100Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.401211Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.401211Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.401239Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.401262Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.401313Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.401346Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.401405Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.401444Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.401465Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.401471Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.401585Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.401651Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.401684Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.401703Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query test-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.401740Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.401787Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.401848Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.401868Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.401937Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.402025Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.402044Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query test-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.402062Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'test-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.402127Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.402147Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.402164Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.402169Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.402184Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.402339Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'test-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.402397Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.402414Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.402429Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.402447Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.386409Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.405715Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.405740Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.405765Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:41:39.406215Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: agg-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:41:39.406236Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' is configured for auto-start (will be started by caller)
[INFO] [stdout] [2m2026-10-06T15:41:39.406253Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.406267Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.406421Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.406449Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.406463Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.406477Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.406506Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.406564Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-agg-test'
[INFO] [stdout] [2m2026-10-06T15:41:39.406683Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-agg-test'
[INFO] [stdout] [2m2026-10-06T15:41:39.406710Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.406745Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.406880Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.406898Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.406922Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: agg-query
[INFO] [stdout] [2m2026-10-06T15:41:39.406981Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: agg-query
[INFO] [stdout] [2m2026-10-06T15:41:39.407691Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.410596Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'agg-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.410663Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.410750Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.410864Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.410902Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.410927Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.410969Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.411130Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.411152Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.391259Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.413118Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.413164Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'test-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.413198Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.413270Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.413373Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.413399Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.413420Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.413460Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.415730Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.415759Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.394578Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.416146Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.416179Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.416192Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.416204Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.416237Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.416266Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.416317Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.416335Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.416361Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.416486Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.416508Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.416555Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.416639Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.417289Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.417340Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'test-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.417377Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.417451Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.421561Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.421870Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.421999Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0magg-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.422051Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0magg-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.422105Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0magg-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.422194Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0magg-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.422316Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.422337Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query agg-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.422562Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'agg-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.422801Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'agg-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.422869Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.422885Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.422899Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.422921Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.424475Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.424618Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.424752Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.425229Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.387810Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.425561Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.425737Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting all auto-start components in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.425915Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:41:39.426269Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:41:39.426472Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Starting component graph source for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.427496Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source started for instance 'file-reaction-integration'
[INFO] [stdout] [2m2026-10-06T15:41:39.428702Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:41:39.428933Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.429238Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.429471Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:41:39.429562Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.429776Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.426760Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.429972Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query test-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.432467Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.398496Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.432983Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.434719Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query test-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.435360Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.435958Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'test-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.439669Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.439692Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.439707Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.439727Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.436511Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'test-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.432239Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' subscribing to 1 sources: ["test-source"]
[INFO] [stdout] [2m2026-10-06T15:41:39.441958Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Query 'test-query' subscribing to Application source 'test-source' (bootstrap: false, resume_from: None, request_handle: false)
[INFO] [stdout] [2m2026-10-06T15:41:39.439566Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.442344Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.442435Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.443331Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.443766Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.443839Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.441436Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.444444Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.444483Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.444580Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.445621Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.442063Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' successfully subscribed to source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.446596Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:41:39.446971Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.447009Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.447103Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.447190Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.447514Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Running - Component graph source running
[INFO] [stdout] [2m2026-10-06T15:41:39.447553Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Running - File reaction started
[INFO] [stdout] [2m2026-10-06T15:41:39.447742Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.447849Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.448172Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.448277Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.448372Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.448391Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query test-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.448550Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.448754Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'test-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.448822Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.448837Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.448852Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.448871Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.450629Z[0m [32m INFO[0m [1mapplication_source_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-source [3mcomponent_type[0m[2m=[0m"source"[1m}[0m[2m:[0m [2mdrasi_source_application[0m[2m:[0m ApplicationSource 'test-source' event processor started
[INFO] [stdout] [2m2026-10-06T15:41:39.450764Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' waiting for bootstrap gate before processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.450952Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' bootstrap gate opened, starting event processing
[INFO] [stdout] [2m2026-10-06T15:41:39.451026Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Starting FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.451126Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' starting priority queue event processor
[INFO] [stdout] [2m2026-10-06T15:41:39.451219Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:41:39.451236Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Query test-query: Running - Query started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.451383Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' received subscription from reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.451596Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m [file-reaction] Fresh start for query 'test-query' — skipping retained history, subscribe_as_of=0
[INFO] [stdout] [2m2026-10-06T15:41:39.451654Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.451670Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start components started in sequence: Sources → Queries → Reactions
[INFO] [stdout] [2m2026-10-06T15:41:39.451684Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m [STARTUP-COMPLETE] DrasiLib.start() is now returning - all components and subscriptions should be active
[INFO] [stdout] [2m2026-10-06T15:41:39.451703Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.454547Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.454650Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.455201Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.455272Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:41:39.455336Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.455380Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.455403Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.455446Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.455508Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.455670Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.455705Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.455745Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.455828Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Stopped - Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.455943Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.456034Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.456076Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.456160Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' received shutdown signal, exiting processing loop
[INFO] [stdout] [2m2026-10-06T15:41:39.456215Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' processing task exited
[INFO] [stdout] [2m2026-10-06T15:41:39.456362Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.456404Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.456436Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.456472Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.456510Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.456549Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.459614Z[0m [33m WARN[0m [2mdrasi_reaction_file::file[0m[2m:[0m Repaired partial trailing line in '/tmp/.tmpdHo3eG/test-query.ndjson': truncated from 40 to 27 bytes
[INFO] [stdout] test test_file_reaction_append_insert_update_delete ... ok
[INFO] [stdout] [2m2026-10-06T15:41:39.496208Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.496357Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.496429Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.496495Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:41:39.496574Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.496624Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.496648Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.496694Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.496758Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.496915Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.496948Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.496984Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.497055Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Stopped - Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.497166Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.497253Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.497298Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.497389Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' received shutdown signal, exiting processing loop
[INFO] [stdout] [2m2026-10-06T15:41:39.497442Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' processing task exited
[INFO] [stdout] [2m2026-10-06T15:41:39.497636Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.497677Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.497708Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.497746Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.497790Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.497809Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] test test_file_reaction_append_fsync_produces_valid_ndjson ... ok
[INFO] [stdout] [2m2026-10-06T15:41:39.502758Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.502905Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.502968Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.503027Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:41:39.503083Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.503130Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.503155Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.503203Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.503274Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.503447Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.503483Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.503547Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.503625Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Stopped - Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.503743Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.503847Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.503883Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.503968Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' received shutdown signal, exiting processing loop
[INFO] [stdout] [2m2026-10-06T15:41:39.504032Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' processing task exited
[INFO] [stdout] [2m2026-10-06T15:41:39.504204Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.504253Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.504289Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.504330Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.504369Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.504385Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.504922Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] test test_file_reaction_per_change_and_payload_filename ... [2m2026-10-06T15:41:39.505014Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] ok
[INFO] [stdout] [2m2026-10-06T15:41:39.505060Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.505104Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:41:39.505150Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.505186Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.505208Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.505246Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.505399Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.505542Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.505578Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.505609Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.505635Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.505671Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Stopped - Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.505717Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.505765Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.505831Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:41:39.505881Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.505918Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.505940Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.505981Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.506038Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.505771Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506133Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506158Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.506168Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506192Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506229Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:41:39.506235Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' received shutdown signal, exiting processing loop
[INFO] [stdout] [2m2026-10-06T15:41:39.506290Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' processing task exited
[INFO] [stdout] [2m2026-10-06T15:41:39.506300Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Stopped - Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.506407Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506429Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.506469Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.506490Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506500Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.506545Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.506556Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.506592Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.506607Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.506616Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' received shutdown signal, exiting processing loop
[INFO] [stdout] [2m2026-10-06T15:41:39.506666Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-integration [3mcomponent_id[0m[2m=[0mtest-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' processing task exited
[INFO] [stdout] [2m2026-10-06T15:41:39.506811Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.506851Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.506883Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.506916Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.506948Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.506962Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] test test_file_reaction_append_recovers_from_partial_line ... ok
[INFO] [stdout] test test_file_reaction_fallback_raw_json ... ok
[INFO] [stdout] [2m2026-10-06T15:41:39.527051Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:41:39.527188Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.527253Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:41:39.527318Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:41:39.527376Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.527423Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.527445Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:41:39.527490Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:41:39.527576Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.527745Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.527777Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.527811Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: agg-query
[INFO] [stdout] [2m2026-10-06T15:41:39.527873Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Reaction file-reaction: Stopped - Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.527971Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.528046Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.528079Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:41:39.528159Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0magg-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' received shutdown signal, exiting processing loop
[INFO] [stdout] [2m2026-10-06T15:41:39.528207Z[0m [32m INFO[0m [1mquery_processor[0m[1m{[0m[3minstance_id[0m[2m=[0mfile-reaction-agg-test [3mcomponent_id[0m[2m=[0magg-query [3mcomponent_type[0m[2m=[0m"query"[1m}[0m[2m:[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' processing task exited
[INFO] [stdout] [2m2026-10-06T15:41:39.528381Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'agg-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:41:39.528418Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'agg-query' stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.528443Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.528474Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:41:39.528506Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:41:39.528561Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] test test_file_reaction_aggregation_uses_updated_template ... ok
[INFO] [stdout] test test_file_reaction_overwrite_mode_keeps_latest ... FAILED
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- test_file_reaction_overwrite_mode_keeps_latest stdout ----
[INFO] [stdout] 
[INFO] [stdout] thread 'test_file_reaction_overwrite_mode_keeps_latest' (2886) panicked at tests/integration_test.rs:231:5:
[INFO] [stdout] assertion failed: content.contains(r#""name":"Latest""#)
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0:     0x616d15bf33c1 - std[617be2ca0a6fd877]::backtrace_rs::backtrace::libunwind::trace
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9
[INFO] [stdout]    1:     0x616d15bf33c1 - std[617be2ca0a6fd877]::backtrace_rs::backtrace::trace_unsynchronized::<std[617be2ca0a6fd877]::sys::backtrace::_print_fmt::{closure#1}>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14
[INFO] [stdout]    2:     0x616d15bf33c1 - std[617be2ca0a6fd877]::sys::backtrace::_print_fmt
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/sys/backtrace.rs:74:9
[INFO] [stdout]    3:     0x616d15bf33c1 - <<std[617be2ca0a6fd877]::sys::backtrace::BacktraceLock>::print::DisplayBacktrace as core[a373ad73a504971]::fmt::Display>::fmt
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/sys/backtrace.rs:44:26
[INFO] [stdout]    4:     0x616d15c0c4ea - <core[a373ad73a504971]::fmt::rt::Argument>::fmt
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/fmt/rt.rs:152:76
[INFO] [stdout]    5:     0x616d15c0c4ea - core[a373ad73a504971]::fmt::write
[INFO] [stdout]    6:     0x616d15bf813c - core[a373ad73a504971]::io::write::default_write_fmt::<alloc[2e1b2a31b91974c5]::vec::Vec<u8>>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/io/write.rs:402:11
[INFO] [stdout]    7:     0x616d15bf813c - <alloc[2e1b2a31b91974c5]::vec::Vec<u8> as core[a373ad73a504971]::io::write::Write>::write_fmt
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/io/write.rs:335:13
[INFO] [stdout]    8:     0x616d15bcc706 - <std[617be2ca0a6fd877]::sys::backtrace::BacktraceLock>::print
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/sys/backtrace.rs:47:9
[INFO] [stdout]    9:     0x616d15bcc706 - std[617be2ca0a6fd877]::panicking::default_hook::{closure#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:289:27
[INFO] [stdout]   10:     0x616d15bea3f9 - std[617be2ca0a6fd877]::panicking::default_hook
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:313:9
[INFO] [stdout]   11:     0x616d14eaaef0 - <alloc[2e1b2a31b91974c5]::boxed::Box<dyn for<'a, 'b> core[a373ad73a504971]::ops::function::Fn<(&'a std[617be2ca0a6fd877]::panic::PanicHookInfo<'b>,), Output = ()> + core[a373ad73a504971]::marker::Sync + core[a373ad73a504971]::marker::Send> as core[a373ad73a504971]::ops::function::Fn<(&std[617be2ca0a6fd877]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/alloc/src/boxed.rs:2328:9
[INFO] [stdout]   12:     0x616d14eaaef0 - test[aada8e7e76ba119b]::test_main_inner::{closure#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/test/src/lib.rs:137:21
[INFO] [stdout]   13:     0x616d15bea722 - <alloc[2e1b2a31b91974c5]::boxed::Box<dyn for<'a, 'b> core[a373ad73a504971]::ops::function::Fn<(&'a std[617be2ca0a6fd877]::panic::PanicHookInfo<'b>,), Output = ()> + core[a373ad73a504971]::marker::Sync + core[a373ad73a504971]::marker::Send> as core[a373ad73a504971]::ops::function::Fn<(&std[617be2ca0a6fd877]::panic::PanicHookInfo,)>>::call
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/alloc/src/boxed.rs:2328:9
[INFO] [stdout]   14:     0x616d15bea722 - std[617be2ca0a6fd877]::panicking::panic_with_hook
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:819:13
[INFO] [stdout]   15:     0x616d15bcc7e4 - std[617be2ca0a6fd877]::panicking::panic_handler::{closure#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:678:13
[INFO] [stdout]   16:     0x616d15bc4bf9 - std[617be2ca0a6fd877]::sys::backtrace::__rust_end_short_backtrace::<std[617be2ca0a6fd877]::panicking::panic_handler::{closure#0}, !>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/sys/backtrace.rs:182:18
[INFO] [stdout]   17:     0x616d15bcd5bd - __rustc[ea4f61d10b84890b]::rust_begin_unwind
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:676:5
[INFO] [stdout]   18:     0x616d15c0cdbc - core[a373ad73a504971]::panicking::panic_fmt
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/panicking.rs:80:14
[INFO] [stdout]   19:     0x616d15c0cd82 - core[a373ad73a504971]::panicking::panic
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/panicking.rs:150:5
[INFO] [stdout]   20:     0x616d14e2826a - integration_test[8d81eae5ae901006]::test_file_reaction_overwrite_mode_keeps_latest::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/integration_test.rs:231:5
[INFO] [stdout]   21:     0x616d14e51d05 - <core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>> as core[a373ad73a504971]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/future/future.rs:133:9
[INFO] [stdout]   22:     0x616d14e51d7d - <core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>> as core[a373ad73a504971]::future::future::Future>::poll
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/future/future.rs:133:9
[INFO] [stdout]   23:     0x616d14e6ff6d - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:830:70
[INFO] [stdout]   24:     0x616d14e6fe98 - tokio[1b1e258a6ce3a29e]::task::coop::with_budget::<core[a373ad73a504971]::task::poll::Poll<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>, <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/task/coop/mod.rs:167:5
[INFO] [stdout]   25:     0x616d14e6fe98 - tokio[1b1e258a6ce3a29e]::task::coop::budget::<core[a373ad73a504971]::task::poll::Poll<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>, <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/task/coop/mod.rs:133:5
[INFO] [stdout]   26:     0x616d14e6fe98 - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:830:25
[INFO] [stdout]   27:     0x616d14e69df7 - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Context>::enter::<core[a373ad73a504971]::task::poll::Poll<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>, <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:488:19
[INFO] [stdout]   28:     0x616d14e6ef0d - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:829:44
[INFO] [stdout]   29:     0x616d14e6e16b - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:906:68
[INFO] [stdout]   30:     0x616d14e7abca - <tokio[1b1e258a6ce3a29e]::runtime::context::scoped::Scoped<tokio[1b1e258a6ce3a29e]::runtime::scheduler::Context>>::set::<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>::{closure#0}, (alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>)>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/context/scoped.rs:40:9
[INFO] [stdout]   31:     0x616d14e33b9a - tokio[1b1e258a6ce3a29e]::runtime::context::set_scheduler::<(alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>), <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>::{closure#0}>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/context.rs:187:38
[INFO] [stdout]   32:     0x616d14e3255c - <std[617be2ca0a6fd877]::thread::local::LocalKey<tokio[1b1e258a6ce3a29e]::runtime::context::Context>>::try_with::<tokio[1b1e258a6ce3a29e]::runtime::context::set_scheduler<(alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>), <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>::{closure#0}>::{closure#0}, (alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>)>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/thread/local.rs:463:12
[INFO] [stdout]   33:     0x616d14e320ec - <std[617be2ca0a6fd877]::thread::local::LocalKey<tokio[1b1e258a6ce3a29e]::runtime::context::Context>>::with::<tokio[1b1e258a6ce3a29e]::runtime::context::set_scheduler<(alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>), <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>::{closure#0}>::{closure#0}, (alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>)>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/thread/local.rs:427:20
[INFO] [stdout]   34:     0x616d14e33421 - tokio[1b1e258a6ce3a29e]::runtime::context::set_scheduler::<(alloc[2e1b2a31b91974c5]::boxed::Box<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::Core>, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>), <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>::{closure#0}>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/context.rs:187:17
[INFO] [stdout]   35:     0x616d14e6bec9 - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::enter::<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>::{closure#0}, core[a373ad73a504971]::option::Option<core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:906:27
[INFO] [stdout]   36:     0x616d14e6c1f6 - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CoreGuard>::block_on::<core[a373ad73a504971]::pin::Pin<&mut core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:817:24
[INFO] [stdout]   37:     0x616d14e6deb9 - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:218:33
[INFO] [stdout]   38:     0x616d14e60268 - tokio[1b1e258a6ce3a29e]::runtime::context::runtime::enter_runtime::<<tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CurrentThread>::block_on<core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>::{closure#0}, core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/context/runtime.rs:65:16
[INFO] [stdout]   39:     0x616d14e69234 - <tokio[1b1e258a6ce3a29e]::runtime::scheduler::current_thread::CurrentThread>::block_on::<core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/scheduler/current_thread/mod.rs:206:9
[INFO] [stdout]   40:     0x616d14e3c3f4 - <tokio[1b1e258a6ce3a29e]::runtime::runtime::Runtime>::block_on_inner::<core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/runtime.rs:374:52
[INFO] [stdout]   41:     0x616d14e3c561 - <tokio[1b1e258a6ce3a29e]::runtime::runtime::Runtime>::block_on::<core[a373ad73a504971]::pin::Pin<&mut dyn core[a373ad73a504971]::future::future::Future<Output = core[a373ad73a504971]::result::Result<(), anyhow[5742dc27d2c32ed7]::Error>>>>
[INFO] [stdout]                                at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.53.1/src/runtime/runtime.rs:343:18
[INFO] [stdout]   42:     0x616d14e30972 - integration_test[8d81eae5ae901006]::test_file_reaction_overwrite_mode_keeps_latest
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/integration_test.rs:234:7
[INFO] [stdout]   43:     0x616d14e23057 - integration_test[8d81eae5ae901006]::test_file_reaction_overwrite_mode_keeps_latest::{closure#0}
[INFO] [stdout]                                at /opt/rustwide/workdir/tests/integration_test.rs:183:62
[INFO] [stdout]   44:     0x616d14e01a76 - <integration_test[8d81eae5ae901006]::test_file_reaction_overwrite_mode_keeps_latest::{closure#0} as core[a373ad73a504971]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   45:     0x616d14e9e33b - <fn() -> core[a373ad73a504971]::result::Result<(), alloc[2e1b2a31b91974c5]::string::String> as core[a373ad73a504971]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   46:     0x616d14e9e33b - test[aada8e7e76ba119b]::__rust_begin_short_backtrace::<core[a373ad73a504971]::result::Result<(), alloc[2e1b2a31b91974c5]::string::String>, fn() -> core[a373ad73a504971]::result::Result<(), alloc[2e1b2a31b91974c5]::string::String>>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/test/src/lib.rs:701:18
[INFO] [stdout]   47:     0x616d14eab515 - test[aada8e7e76ba119b]::run_test_in_process::{closure#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/test/src/lib.rs:724:74
[INFO] [stdout]   48:     0x616d14eab515 - <core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<test[aada8e7e76ba119b]::run_test_in_process::{closure#0}> as core[a373ad73a504971]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   49:     0x616d14eab515 - std[617be2ca0a6fd877]::panicking::catch_unwind::do_call::<core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<test[aada8e7e76ba119b]::run_test_in_process::{closure#0}>, core[a373ad73a504971]::result::Result<(), alloc[2e1b2a31b91974c5]::string::String>>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:573:43
[INFO] [stdout]   50:     0x616d14eab515 - std[617be2ca0a6fd877]::panicking::catch_unwind::<core[a373ad73a504971]::result::Result<(), alloc[2e1b2a31b91974c5]::string::String>, core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<test[aada8e7e76ba119b]::run_test_in_process::{closure#0}>>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:541:19
[INFO] [stdout]   51:     0x616d14eab515 - std[617be2ca0a6fd877]::panic::catch_unwind::<core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<test[aada8e7e76ba119b]::run_test_in_process::{closure#0}>, core[a373ad73a504971]::result::Result<(), alloc[2e1b2a31b91974c5]::string::String>>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panic.rs:359:14
[INFO] [stdout]   52:     0x616d14eab515 - test[aada8e7e76ba119b]::run_test_in_process
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/test/src/lib.rs:724:27
[INFO] [stdout]   53:     0x616d14eab515 - test[aada8e7e76ba119b]::run_test::{closure#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/test/src/lib.rs:645:43
[INFO] [stdout]   54:     0x616d14ea4e04 - test[aada8e7e76ba119b]::run_test::{closure#1}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/test/src/lib.rs:675:41
[INFO] [stdout]   55:     0x616d14ea4e04 - std[617be2ca0a6fd877]::sys::backtrace::__rust_begin_short_backtrace::<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/sys/backtrace.rs:166:18
[INFO] [stdout]   56:     0x616d14eae5a2 - std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked::<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/thread/lifecycle.rs:70:13
[INFO] [stdout]   57:     0x616d14eae5a2 - <core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}> as core[a373ad73a504971]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/panic/unwind_safe.rs:275:9
[INFO] [stdout]   58:     0x616d14eae5a2 - std[617be2ca0a6fd877]::panicking::catch_unwind::do_call::<core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:573:43
[INFO] [stdout]   59:     0x616d14eae5a2 - std[617be2ca0a6fd877]::panicking::catch_unwind::<(), core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panicking.rs:541:19
[INFO] [stdout]   60:     0x616d14eae5a2 - std[617be2ca0a6fd877]::panic::catch_unwind::<core[a373ad73a504971]::panic::unwind_safe::AssertUnwindSafe<std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1}::{closure#0}>, ()>
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/panic.rs:359:14
[INFO] [stdout]   61:     0x616d14eae5a2 - std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked::<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/thread/lifecycle.rs:68:26
[INFO] [stdout]   62:     0x616d14eae5a2 - <std[617be2ca0a6fd877]::thread::lifecycle::spawn_unchecked<test[aada8e7e76ba119b]::run_test::{closure#1}, ()>::{closure#1} as core[a373ad73a504971]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0}
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   63:     0x616d15bf238f - <alloc[2e1b2a31b91974c5]::boxed::Box<dyn core[a373ad73a504971]::ops::function::FnOnce<(), Output = ()> + core[a373ad73a504971]::marker::Send> as core[a373ad73a504971]::ops::function::FnOnce<()>>::call_once
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/alloc/src/boxed.rs:2314:9
[INFO] [stdout]   64:     0x616d15bf238f - <std[617be2ca0a6fd877]::sys::thread::unix::Thread>::new::thread_start
[INFO] [stdout]                                at /rustc/e3feeb59cd1bdd011a2bfcc0747b55125d9b8527/library/std/src/sys/thread/unix.rs:127:17
[INFO] [stdout]   65:     0x7875879addfa - <unknown>
[INFO] [stdout]   66:     0x787587a413d4 - clone
[INFO] [stdout]   67:                0x0 - <unknown>
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     test_file_reaction_overwrite_mode_keeps_latest
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 6 passed; 1 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.26s
[INFO] [stdout] 
[INFO] [stderr] error: test failed, to rerun pass `--test integration_test`
[INFO] running `Command { std: "docker" "inspect" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447", kill_on_drop: false }`
[INFO] [stdout] 6a9de147f9bcfde3378e7238b860b055376380b01d2b4963d66fed687896d447
