[INFO] fetching crate drasi-reaction-file 0.1.6...
[INFO] testing drasi-reaction-file-0.1.6 against 1.99.0-beta.8 for beta-1.100-2
[INFO] extracting crate drasi-reaction-file 0.1.6 into /workspace/builds/worker-5-tc1/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-tc1/source/Cargo.toml
[INFO] validating manifest of crates.io crate drasi-reaction-file 0.1.6 on toolchain 1.99.0-beta.8
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate 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.99.0-beta.8" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded utoipa-gen v4.3.1
[INFO] [stderr]   Downloaded peg-runtime v0.8.6
[INFO] [stderr]   Downloaded drasi-query-cypher v0.3.6
[INFO] [stderr]   Downloaded tokio-test v0.4.6
[INFO] [stderr]   Downloaded drasi-query-ast v0.3.5
[INFO] [stderr]   Downloaded round v0.1.2
[INFO] [stderr]   Downloaded statistical v1.0.0
[INFO] [stderr]   Downloaded drasi-functions-gql v0.5.10
[INFO] [stderr]   Downloaded peg v0.8.6
[INFO] [stderr]   Downloaded rand_core v0.3.2
[INFO] [stderr]   Downloaded iso8601-duration v0.2.0
[INFO] [stderr]   Downloaded phf_shared v0.12.1
[INFO] [stderr]   Downloaded drasi-functions-cypher v0.5.10
[INFO] [stderr]   Downloaded drasi-ffi-primitives v0.11.3
[INFO] [stderr]   Downloaded opentelemetry v0.20.0
[INFO] [stderr]   Downloaded siphasher v1.0.4
[INFO] [stderr]   Downloaded pest_derive v2.9.2
[INFO] [stderr]   Downloaded drasi-query-gql v0.3.6
[INFO] [stderr]   Downloaded rand_core v0.4.3
[INFO] [stderr]   Downloaded dateparser v0.2.1
[INFO] [stderr]   Downloaded utoipa v4.2.3
[INFO] [stderr]   Downloaded phf v0.12.1
[INFO] [stderr]   Downloaded rmp-serde v1.3.1
[INFO] [stderr]   Downloaded pest_meta v2.9.2
[INFO] [stderr]   Downloaded rmp v0.8.15
[INFO] [stderr]   Downloaded peg-macros v0.8.6
[INFO] [stderr]   Downloaded priority-queue v1.4.0
[INFO] [stderr]   Downloaded handlebars v5.1.2
[INFO] [stderr]   Downloaded pest_generator v2.9.2
[INFO] [stderr]   Downloaded opentelemetry_api v0.20.0
[INFO] [stderr]   Downloaded caches v0.2.8
[INFO] [stderr]   Downloaded opentelemetry_sdk v0.20.0
[INFO] [stderr]   Downloaded pest v2.9.2
[INFO] [stderr]   Downloaded cc v1.5.1
[INFO] [stderr]   Downloaded drasi-plugin-sdk v0.11.3
[INFO] [stderr]   Downloaded drasi-core v0.5.10
[INFO] [stderr]   Downloaded rustix v1.1.5
[INFO] [stderr]   Downloaded drasi-lib v0.9.3
[INFO] [stderr]   Downloaded hashers v1.0.1
[INFO] [stderr]   Downloaded chrono-tz v0.10.4
[INFO] [stderr]   Downloaded drasi-source-application v0.2.11
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:3111399a4047eeb3a02b7a90e478d715f38a8c6669b5c4b49d30a17385265909" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] 152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f
[INFO] running `Command { std: "docker" "start" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", 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" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", 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" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.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 futures-sink v0.3.34
[INFO] [stderr]    Compiling autocfg v0.1.8
[INFO] [stderr]    Compiling futures-channel v0.3.34
[INFO] [stderr]    Compiling rand_core v0.3.2
[INFO] [stderr]    Compiling futures-task v0.3.34
[INFO] [stderr]    Compiling num-traits v0.2.19
[INFO] [stderr]    Compiling indexmap v1.9.3
[INFO] [stderr]    Compiling anyhow v1.0.104
[INFO] [stderr]    Compiling futures-io v0.3.34
[INFO] [stderr]    Compiling aho-corasick v1.1.5
[INFO] [stderr]    Compiling num-bigint v0.2.6
[INFO] [stderr]    Compiling hashbrown v0.12.3
[INFO] [stderr]    Compiling regex-syntax v0.8.11
[INFO] [stderr]    Compiling syn v3.0.6
[INFO] [stderr]    Compiling syn v2.0.119
[INFO] [stderr]    Compiling num-integer v0.1.47
[INFO] [stderr]    Compiling getrandom v0.2.17
[INFO] [stderr]    Compiling rand_core v0.6.4
[INFO] [stderr]    Compiling crossbeam-utils v0.8.23
[INFO] [stderr]    Compiling smallvec v1.16.2
[INFO] [stderr]    Compiling rand_chacha v0.1.1
[INFO] [stderr]    Compiling num-complex v0.2.4
[INFO] [stderr]    Compiling rand_pcg v0.1.2
[INFO] [stderr]    Compiling num-rational v0.2.4
[INFO] [stderr]    Compiling peg-runtime v0.8.6
[INFO] [stderr]    Compiling radium v0.7.0
[INFO] [stderr]    Compiling bytes v1.12.1
[INFO] [stderr]    Compiling peg-macros v0.8.6
[INFO] [stderr]    Compiling serde_json v1.0.151
[INFO] [stderr]    Compiling regex-automata v0.4.18
[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 urlencoding v2.1.3
[INFO] [stderr]    Compiling siphasher v1.0.4
[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 phf_shared v0.12.1
[INFO] [stderr]    Compiling peg v0.8.6
[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 num-iter v0.1.46
[INFO] [stderr]    Compiling socket2 v0.6.5
[INFO] [stderr]    Compiling rand_os v0.1.3
[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 mio v1.2.3
[INFO] [stderr]    Compiling futures-util v0.3.34
[INFO] [stderr]    Compiling priority-queue v1.4.0
[INFO] [stderr]    Compiling rand_xorshift v0.1.1
[INFO] [stderr]    Compiling rand_hc v0.1.0
[INFO] [stderr]    Compiling rand_isaac v0.1.1
[INFO] [stderr]    Compiling rand_jitter v0.1.4
[INFO] [stderr]    Compiling chrono-tz v0.10.4
[INFO] [stderr]    Compiling time-core v0.1.9
[INFO] [stderr]    Compiling num-conv v0.2.2
[INFO] [stderr]    Compiling funty v2.0.0
[INFO] [stderr]    Compiling fxhash v0.2.1
[INFO] [stderr]    Compiling nom v7.1.3
[INFO] [stderr]    Compiling time-macros v0.2.32
[INFO] [stderr]    Compiling thiserror-impl v1.0.69
[INFO] [stderr]    Compiling tracing-attributes v0.1.31
[INFO] [stderr]    Compiling bitvec v1.1.1
[INFO] [stderr]    Compiling thiserror v1.0.69
[INFO] [stderr]    Compiling async-stream-impl v0.3.6
[INFO] [stderr]    Compiling regex v1.13.1
[INFO] [stderr]    Compiling tracing v0.1.44
[INFO] [stderr]    Compiling tokio v1.53.1
[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 uuid v1.26.1
[INFO] [stderr]    Compiling drasi-query-ast v0.3.5
[INFO] [stderr]    Compiling futures-executor v0.3.34
[INFO] [stderr]    Compiling opentelemetry_api v0.20.0
[INFO] [stderr]    Compiling ordered-float v3.9.2
[INFO] [stderr]    Compiling chrono v0.4.45
[INFO] [stderr]    Compiling caches v0.2.8
[INFO] [stderr]    Compiling futures v0.3.34
[INFO] [stderr]    Compiling drasi-query-cypher v0.3.6
[INFO] [stderr]    Compiling time v0.3.55
[INFO] [stderr]    Compiling indexmap v2.14.2
[INFO] [stderr]    Compiling opentelemetry_sdk v0.20.0
[INFO] [stderr]    Compiling statistical v1.0.0
[INFO] [stderr]    Compiling async-stream v0.3.6
[INFO] [stderr]    Compiling iso8601-duration v0.2.0
[INFO] [stderr]    Compiling async-recursion v1.1.1
[INFO] [stderr]    Compiling hashers v1.0.1
[INFO] [stderr]    Compiling approx v0.5.1
[INFO] [stderr]    Compiling dateparser v0.2.1
[INFO] [stderr]    Compiling opentelemetry v0.20.0
[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 bitmaps v2.1.0
[INFO] [stderr]    Compiling im v15.1.0
[INFO] [stderr]    Compiling either v1.18.0
[INFO] [stderr]    Compiling thiserror v2.0.21
[INFO] [stderr]    Compiling sized-chunks v0.6.5
[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 tracing-log v0.2.0
[INFO] [stderr]    Compiling rand_xoshiro v0.6.0
[INFO] [stderr]    Compiling pest_meta v2.9.2
[INFO] [stderr]    Compiling rmp v0.8.15
[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 tokio-stream v0.1.19
[INFO] [stderr]    Compiling prost-derive v0.12.6
[INFO] [stderr]    Compiling pest_generator v2.9.2
[INFO] [stderr]    Compiling drasi-plugin-sdk v0.11.3
[INFO] [stderr]    Compiling serde_yaml v0.9.34+deprecated
[INFO] [stderr]    Compiling petgraph v0.6.5
[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]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 3m 09s
[INFO] running `Command { std: "docker" "inspect" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", 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" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]    Compiling 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-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-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]     Finished `test` profile [unoptimized + debuginfo] target(s) in 1m 05s
[INFO] running `Command { std: "docker" "inspect" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", 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" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f" "/opt/rustwide/cargo-home/bin/cargo" "+1.99.0-beta.8" "test" "--frozen", kill_on_drop: false }`
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.39s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/drasi_reaction_file-0ebf9c864dc9af41)
[INFO] [stdout] 
[INFO] [stdout] running 25 tests
[INFO] [stdout] test descriptor::tests::test_template_spec_dto_to_domain ... ok
[INFO] [stdout] test descriptor::tests::test_create_reaction_from_config_json ... ok
[INFO] [stdout] test file::tests::test_empty_output_path_fails_build ... ok
[INFO] [stdout] test file::tests::test_invalid_label_template_fails_build ... ok
[INFO] [stdout] test descriptor::tests::test_write_mode_dto_roundtrip ... ok
[INFO] [stdout] test descriptor::tests::test_query_config_dto_to_domain ... ok
[INFO] [stdout] test descriptor::tests::test_full_config_dto_roundtrip ... ok
[INFO] [stdout] test file::tests::test_invalid_route_fails_build ... ok
[INFO] [stdout] test file::tests::test_invalid_template_fails_build ... ok
[INFO] [stdout] test file::tests::test_default_template_route_lookup ... ok
[INFO] [stdout] test file::tests::test_fallback_to_raw_json_when_no_template ... ok
[INFO] [stdout] test file::tests::test_query_route_no_match_falls_to_default ... 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_render_output_aggregation ... ok
[INFO] [stdout] test file::tests::test_repair_partial_line_empty_file_is_no_op ... ok
[INFO] [stdout] test file::tests::test_sanitize_filename ... ok
[INFO] [stdout] test file::tests::test_sanitize_filename_reserved_windows_names ... ok
[INFO] [stdout] test file::tests::test_sanitize_filename_control_chars ... ok
[INFO] [stdout] test file::tests::test_repair_partial_line_entire_file_is_partial ... ok
[INFO] [stdout] test file::tests::test_render_output_delete ... ok
[INFO] [stdout] test file::tests::test_render_output_update ... ok
[INFO] [stdout] test file::tests::test_query_route_overrides_default ... ok
[INFO] [stdout] test file::tests::test_repair_append_file_once_only_repairs_first_time ... 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/deps/integration_test-ddc4ed9c18a4adf0)
[INFO] [stdout] 
[INFO] [stdout] running 7 tests
[INFO] [stdout] [2m2026-10-06T15:37:18.417152Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.417315Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.417336Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.417359Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.417970Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.418088Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.418108Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.418133Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.418447Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.418841Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.418865Z[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:37:18.418882Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.418894Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.419052Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.419080Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.419095Z[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:37:18.419109Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.419141Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.419179Z[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:37:18.419240Z[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:37:18.419260Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.419318Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.419478Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.419496Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.419613Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.419631Z[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:37:18.419647Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.419660Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.419801Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.419826Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.419837Z[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:37:18.419849Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.419878Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.419889Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.419905Z[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:37:18.419945Z[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:37:18.419959Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.419982Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.420014Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.420032Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.420054Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.420076Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.420089Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.420109Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.420176Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.420472Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: agg-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.420492Z[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:37:18.420760Z[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:37:18.420799Z[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:37:18.420826Z[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:37:18.420892Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.420949Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.420978Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.421000Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.421025Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.421058Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.421070Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.421090Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.421113Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.421187Z[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:37:18.421204Z[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:37:18.421389Z[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:37:18.421476Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.421475Z[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:37:18.421495Z[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:37:18.421510Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.421543Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.421682Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.421720Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.421735Z[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:37:18.421751Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.421778Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.421809Z[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:37:18.421860Z[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:37:18.421883Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.421930Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.422049Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.422067Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.422092Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.422145Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.422491Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.422611Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.422631Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.422652Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.422998Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.423017Z[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:37:18.423032Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.423043Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.423179Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.423205Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.423218Z[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:37:18.423231Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.423274Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.423307Z[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:37:18.423353Z[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:37:18.423372Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.423400Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.417152Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.423670Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.423700Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.423719Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.424078Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.424098Z[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:37:18.424114Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.424126Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.424274Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.424301Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.424314Z[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:37:18.424327Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.424349Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.424391Z[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:37:18.424441Z[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:37:18.424460Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.424489Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.420508Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.424590Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.424736Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.424760Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.424772Z[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:37:18.424786Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.424809Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.424839Z[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:37:18.424896Z[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:37:18.424913Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.424943Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.425204Z[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:37:18.425244Z[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:37:18.425287Z[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:37:18.425358Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.425458Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.425484Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.425507Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.425565Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.425689Z[0m [32m INFO[0m [2mdrasi_lib::sources::manager[0m[2m:[0m Provisioned source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.425688Z[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:37:18.425707Z[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:37:18.425708Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Initializing drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.425732Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Loading configuration
[INFO] [stdout] [2m2026-10-06T15:37:18.425955Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.426004Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.426058Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.426132Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Provisioned query: test-query with bootstrap support
[INFO] [stdout] [2m2026-10-06T15:37:18.423508Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.426184Z[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:37:18.426188Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.426311Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.426324Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.426332Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.426616Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: agg-query
[INFO] [stdout] [2m2026-10-06T15:37:18.426616Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.426678Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: agg-query
[INFO] [stdout] [2m2026-10-06T15:37:18.427188Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.427275Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.427341Z[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:37:18.427381Z[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:37:18.427422Z[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:37:18.427488Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'agg-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.427606Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.427630Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.427650Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.427688Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.427809Z[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:37:18.427830Z[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:37:18.427886Z[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:37:18.427926Z[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:37:18.427958Z[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:37:18.427979Z[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:37:18.428026Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.428079Z[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:37:18.428128Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.428129Z[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:37:18.428154Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.428178Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.428184Z[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:37:18.428218Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.428277Z[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:37:18.428277Z[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:37:18.428316Z[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:37:18.428349Z[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:37:18.428352Z[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:37:18.428369Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.428374Z[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:37:18.428386Z[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:37:18.428413Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.428514Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.428566Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.428566Z[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:37:18.428548Z[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:37:18.428588Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.428623Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.428661Z[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:37:18.428713Z[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:37:18.428743Z[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:37:18.428743Z[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:37:18.428783Z[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:37:18.428773Z[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:37:18.428815Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.428832Z[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:37:18.428848Z[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:37:18.428869Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.428859Z[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:37:18.428922Z[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:37:18.428953Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.428974Z[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:37:18.429002Z[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:37:18.429049Z[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:37:18.429116Z[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:37:18.429111Z[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:37:18.429190Z[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:37:18.429280Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.429300Z[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:37:18.429299Z[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:37:18.429349Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.429363Z[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:37:18.429376Z[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:37:18.429392Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.429434Z[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:37:18.429618Z[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:37:18.429677Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.429694Z[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:37:18.429708Z[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:37:18.429728Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.421511Z[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:37:18.434126Z[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:37:18.434669Z[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:37:18.436680Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.437204Z[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:37:18.440791Z[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:37:18.426158Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.441605Z[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:37:18.442602Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.443021Z[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:37:18.443450Z[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:37:18.426410Z[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:37:18.443870Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.445563Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Configuration loaded successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.445591Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib initialized successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.445804Z[0m [32m INFO[0m [2mdrasi_lib::reactions::manager[0m[2m:[0m Provisioned reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.445862Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Starting drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.445902Z[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:37:18.445933Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start sources
[INFO] [stdout] [2m2026-10-06T15:37:18.445984Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: __component_graph__
[INFO] [stdout] [2m2026-10-06T15:37:18.449612Z[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:37:18.449710Z[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:37:18.449731Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting source: test-source
[INFO] [stdout] [2m2026-10-06T15:37:18.449785Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Starting ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.449930Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start sources started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.449947Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start queries
[INFO] [stdout] [2m2026-10-06T15:37:18.449978Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting query: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.450045Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.450551Z[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:37:18.450633Z[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:37:18.450697Z[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:37:18.450784Z[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:37:18.450814Z[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:37:18.450870Z[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:37:18.450887Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.450905Z[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:37:18.450906Z[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:37:18.450975Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.451080Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.451092Z[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:37:18.451109Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.451133Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.451172Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.451297Z[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:37:18.451298Z[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:37:18.451319Z[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:37:18.451368Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.451387Z[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:37:18.451404Z[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:37:18.451426Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.451465Z[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:37:18.442271Z[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:37:18.454681Z[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:37:18.457597Z[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:37:18.457716Z[0m [32m INFO[0m [2mdrasi_lib::queries::manager[0m[2m:[0m Query 'test-query' no bootstrap channels, skipping bootstrap
[INFO] [stdout] [2m2026-10-06T15:37:18.457841Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start queries started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.457872Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Starting auto-start reactions
[INFO] [stdout] [2m2026-10-06T15:37:18.457898Z[0m [32m INFO[0m [2mdrasi_lib::managers::lifecycle_helpers[0m[2m:[0m Starting reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.457951Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Starting File Reaction component: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.458107Z[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:37:18.458129Z[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:37:18.458311Z[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:37:18.458416Z[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:37:18.458473Z[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:37:18.458564Z[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:37:18.458673Z[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:37:18.458800Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.458822Z[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:37:18.458965Z[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:37:18.459166Z[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:37:18.459234Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.459251Z[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:37:18.459265Z[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:37:18.459286Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.471709Z[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:37:18.471893Z[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:37:18.473628Z[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:37:18.477845Z[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:37:18.478031Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source test-source: Running - Processing events
[INFO] [stdout] [2m2026-10-06T15:37:18.478563Z[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:37:18.481839Z[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:37:18.482777Z[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:37:18.486659Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All auto-start reactions started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.488212Z[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:37:18.488281Z[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:37:18.488328Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib started successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.480927Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.492690Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.492776Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.492862Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.492934Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.492984Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.493011Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.493068Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.493144Z[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:37:18.493327Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.493367Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.493407Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.493485Z[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:37:18.493617Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.493702Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.493738Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.493878Z[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:37:18.493983Z[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:37:18.494154Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.494194Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.494223Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.494257Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.494304Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.494321Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.495969Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.496059Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.496105Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.496182Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.496234Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.496278Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.496302Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.496346Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.496406Z[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:37:18.496558Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.496595Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.496633Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] test test_file_reaction_fallback_raw_json ... ok
[INFO] [stdout] [2m2026-10-06T15:37:18.496709Z[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:37:18.496811Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.496901Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.496940Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.497057Z[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:37:18.497162Z[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:37:18.497423Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.497462Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.497490Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.497552Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.497597Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.497612Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] test test_file_reaction_per_change_and_payload_filename ... ok
[INFO] [stdout] [2m2026-10-06T15:37:18.501722Z[0m [33m WARN[0m [2mdrasi_reaction_file::file[0m[2m:[0m Repaired partial trailing line in '/tmp/.tmpbAZnVH/test-query.ndjson': truncated from 40 to 27 bytes
[INFO] [stdout] [2m2026-10-06T15:37:18.502969Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.503835Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.503935Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.504022Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.513650Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.513732Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.513788Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.513850Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.513926Z[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:37:18.514083Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.514119Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.514156Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.514221Z[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:37:18.514331Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.514420Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.514457Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.514566Z[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:37:18.514631Z[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:37:18.514817Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.514859Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.514890Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.514925Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.514965Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.514984Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] test test_file_reaction_append_insert_update_delete ... ok
[INFO] [stdout] [2m2026-10-06T15:37:18.531154Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.531299Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.531378Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.531445Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.531509Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.531580Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.531605Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.531654Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.531720Z[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:37:18.531887Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.531922Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.531959Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: agg-query
[INFO] [stdout] [2m2026-10-06T15:37:18.532031Z[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:37:18.532144Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.532235Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.532272Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'agg-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.532358Z[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:37:18.532402Z[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:37:18.532574Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'agg-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.532610Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'agg-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.532638Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.532669Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.532708Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.532723Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.532900Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.532969Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.533010Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.533056Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.533099Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.533129Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.533149Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.533183Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.533231Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Component Event - Source __component_graph__: Stopped - Source '__component_graph__' stopped
[INFO] [stdout] test test_file_reaction_aggregation_uses_updated_template ... ok
[INFO] [stdout] [2m2026-10-06T15:37:18.533394Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.533429Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.533459Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.533512Z[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:37:18.533623Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.533700Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.533737Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.533829Z[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:37:18.533882Z[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:37:18.534021Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.534058Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.534088Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.534122Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.534156Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.534170Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m drasi-lib stopped successfully
[INFO] [stdout] test test_file_reaction_overwrite_mode_keeps_latest ... ok
[INFO] [stdout] [2m2026-10-06T15:37:18.546562Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.546702Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.546782Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.546847Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.546901Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.546948Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.546971Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.547017Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.547081Z[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:37:18.547234Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.547265Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.547301Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.547363Z[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:37:18.547454Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.547547Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.547581Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.547663Z[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:37:18.547713Z[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:37:18.547884Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.547924Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.547953Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.547988Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.548025Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.548042Z[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] [2m2026-10-06T15:37:18.562486Z[0m [32m INFO[0m [2mdrasi_lib::lib_core[0m[2m:[0m Stopping drasi-lib
[INFO] [stdout] [2m2026-10-06T15:37:18.562694Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.562779Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Stopping source '__component_graph__'
[INFO] [stdout] [2m2026-10-06T15:37:18.562836Z[0m [32m INFO[0m [2mdrasi_lib::sources::component_graph_source[0m[2m:[0m Component graph source received shutdown signal
[INFO] [stdout] [2m2026-10-06T15:37:18.562893Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.562940Z[0m [32m INFO[0m [2mdrasi_lib::sources::base[0m[2m:[0m Source '__component_graph__' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.562967Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping reaction 'file-reaction'
[INFO] [stdout] [2m2026-10-06T15:37:18.563015Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Stopping reaction: file-reaction
[INFO] [stdout] [2m2026-10-06T15:37:18.563079Z[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:37:18.563234Z[0m [32m INFO[0m [2mdrasi_lib::reactions::common::base[0m[2m:[0m Reaction 'file-reaction' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.563276Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.563312Z[0m [32m INFO[0m [2mdrasi_lib::managers::logging[0m[2m:[0m Stopping Query component: test-query
[INFO] [stdout] [2m2026-10-06T15:37:18.563380Z[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:37:18.563493Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m Stopping FutureQueueSource for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.563595Z[0m [32m INFO[0m [2mdrasi_lib::sources::future_queue_source[0m[2m:[0m FutureQueueSource stopped for query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.563638Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Stopping query 'test-query'
[INFO] [stdout] [2m2026-10-06T15:37:18.563724Z[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:37:18.563778Z[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:37:18.563961Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' task completed successfully
[INFO] [stdout] [2m2026-10-06T15:37:18.564000Z[0m [32m INFO[0m [2mdrasi_lib::queries::base[0m[2m:[0m Query 'test-query' stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.564028Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m Stopping source 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.564061Z[0m [32m INFO[0m [2mdrasi_source_application[0m[2m:[0m Stopping ApplicationSource 'test-source'
[INFO] [stdout] [2m2026-10-06T15:37:18.564105Z[0m [32m INFO[0m [2mdrasi_lib::lifecycle[0m[2m:[0m All components stopped
[INFO] [stdout] [2m2026-10-06T15:37:18.564123Z[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] 
[INFO] [stdout] test result: ok. 7 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.15s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests drasi_reaction_file
[INFO] [stdout] 
[INFO] [stdout] running 0 tests
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f", kill_on_drop: false }`
[INFO] [stdout] 152faa159e45414469db91f3918d44a639c8c8d41f9c90c552148340747dff5f
