[INFO] cloning repository https://github.com/fbielejec/kafka-s3-sink
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/fbielejec/kafka-s3-sink" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Ffbielejec%2Fkafka-s3-sink", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Ffbielejec%2Fkafka-s3-sink'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 89f20ccd89e4b8a02ab589c50e0a657413498ed2
[INFO] building fbielejec/kafka-s3-sink against try#b755f8b9936d084e0363ce6b393c7e444a37080e for pr-97334-1
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Ffbielejec%2Fkafka-s3-sink" "/workspace/builds/worker-3/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-3/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/fbielejec/kafka-s3-sink on toolchain b755f8b9936d084e0363ce6b393c7e444a37080e
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+b755f8b9936d084e0363ce6b393c7e444a37080e" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/fbielejec/kafka-s3-sink
[INFO] finished tweaking git repo https://github.com/fbielejec/kafka-s3-sink
[INFO] tweaked toml for git repo https://github.com/fbielejec/kafka-s3-sink written to /workspace/builds/worker-3/source/Cargo.toml
[INFO] crate git repo https://github.com/fbielejec/kafka-s3-sink already has a lockfile, it will not be regenerated
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+b755f8b9936d084e0363ce6b393c7e444a37080e" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:824c28ce115f6b999260af6986f3384c158e782489540e41c0b698ca1d9fd927" "/opt/rustwide/cargo-home/bin/cargo" "+b755f8b9936d084e0363ce6b393c7e444a37080e" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 343dabb25d4462023a6b6af33c33346ffc3425395d7283b4597b358bd6b4a859
[INFO] running `Command { std: "docker" "start" "-a" "343dabb25d4462023a6b6af33c33346ffc3425395d7283b4597b358bd6b4a859", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "343dabb25d4462023a6b6af33c33346ffc3425395d7283b4597b358bd6b4a859", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "343dabb25d4462023a6b6af33c33346ffc3425395d7283b4597b358bd6b4a859", kill_on_drop: false }`
[INFO] [stdout] 343dabb25d4462023a6b6af33c33346ffc3425395d7283b4597b358bd6b4a859
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:824c28ce115f6b999260af6986f3384c158e782489540e41c0b698ca1d9fd927" "/opt/rustwide/cargo-home/bin/cargo" "+b755f8b9936d084e0363ce6b393c7e444a37080e" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] aed36d648867cbb3c34b5f5bcddea62e5555b07d1b6621bfc2b50d4ceec0a97c
[INFO] running `Command { std: "docker" "start" "-a" "aed36d648867cbb3c34b5f5bcddea62e5555b07d1b6621bfc2b50d4ceec0a97c", kill_on_drop: false }`
[INFO] [stderr]    Compiling libc v0.2.85
[INFO] [stderr]    Compiling proc-macro2 v1.0.24
[INFO] [stderr]    Compiling unicode-xid v0.2.1
[INFO] [stderr]    Compiling syn v1.0.60
[INFO] [stderr]    Compiling cfg-if v1.0.0
[INFO] [stderr]    Compiling memchr v2.3.4
[INFO] [stderr]    Compiling log v0.4.14
[INFO] [stderr]    Compiling version_check v0.9.2
[INFO] [stderr]    Compiling once_cell v1.5.2
[INFO] [stderr]    Compiling typenum v1.12.0
[INFO] [stderr]    Compiling bytes v1.0.1
[INFO] [stderr]    Compiling pin-project-lite v0.2.4
[INFO] [stderr]    Compiling serde_derive v1.0.123
[INFO] [stderr]    Compiling autocfg v1.0.1
[INFO] [stderr]    Compiling itoa v0.4.7
[INFO] [stderr]    Compiling serde v1.0.123
[INFO] [stderr]    Compiling futures-core v0.3.12
[INFO] [stderr]    Compiling getrandom v0.2.2
[INFO] [stderr]    Compiling proc-macro-hack v0.5.19
[INFO] [stderr]    Compiling proc-macro-nested v0.1.7
[INFO] [stderr]    Compiling smallvec v1.6.1
[INFO] [stderr]    Compiling scopeguard v1.1.0
[INFO] [stderr]    Compiling futures-sink v0.3.12
[INFO] [stderr]    Compiling ppv-lite86 v0.2.10
[INFO] [stderr]    Compiling fnv v1.0.7
[INFO] [stderr]    Compiling futures-io v0.3.12
[INFO] [stderr]    Compiling futures v0.1.30
[INFO] [stderr]    Compiling slab v0.4.2
[INFO] [stderr]    Compiling matches v0.1.8
[INFO] [stderr]    Compiling pin-utils v0.1.0
[INFO] [stderr]    Compiling pin-project-internal v0.4.27
[INFO] [stderr]    Compiling getrandom v0.1.16
[INFO] [stderr]    Compiling pkg-config v0.3.19
[INFO] [stderr]    Compiling httparse v1.3.5
[INFO] [stderr]    Compiling tinyvec_macros v0.1.0
[INFO] [stderr]    Compiling byteorder v1.4.2
[INFO] [stderr]    Compiling lazy_static v1.4.0
[INFO] [stderr]    Compiling percent-encoding v2.1.0
[INFO] [stderr]    Compiling ryu v1.0.5
[INFO] [stderr]    Compiling cc v1.0.66
[INFO] [stderr]    Compiling byte-tools v0.3.1
[INFO] [stderr]    Compiling hashbrown v0.9.1
[INFO] [stderr]    Compiling opaque-debug v0.3.0
[INFO] [stderr]    Compiling serde_json v1.0.61
[INFO] [stderr]    Compiling bitflags v1.2.1
[INFO] [stderr]    Compiling mime v0.3.16
[INFO] [stderr]    Compiling base64 v0.13.0
[INFO] [stderr]    Compiling cpuid-bool v0.1.2
[INFO] [stderr]    Compiling utf-8 v0.7.5
[INFO] [stderr]    Compiling fake-simd v0.1.2
[INFO] [stderr]    Compiling opaque-debug v0.2.3
[INFO] [stderr]    Compiling remove_dir_all v0.5.3
[INFO] [stderr]    Compiling try-lock v0.2.3
[INFO] [stderr]    Compiling safemem v0.3.3
[INFO] [stderr]    Compiling quick-error v1.2.3
[INFO] [stderr]    Compiling httpdate v0.3.2
[INFO] [stderr]    Compiling tower-service v0.3.1
[INFO] [stderr]    Compiling regex-syntax v0.6.22
[INFO] [stderr]    Compiling humantime v2.1.0
[INFO] [stderr]    Compiling scoped-tls v1.0.0
[INFO] [stderr]    Compiling termcolor v1.1.2
[INFO] [stderr]    Compiling maplit v1.0.2
[INFO] [stderr]    Compiling instant v0.1.9
[INFO] [stderr]    Compiling futures-task v0.3.12
[INFO] [stderr]    Compiling thread_local v1.1.3
[INFO] [stderr]    Compiling lock_api v0.4.2
[INFO] [stderr]    Compiling futures-channel v0.3.12
[INFO] [stderr]    Compiling unicode-bidi v0.3.4
[INFO] [stderr]    Compiling http v0.2.3
[INFO] [stderr]    Compiling input_buffer v0.4.0
[INFO] [stderr]    Compiling generic-array v0.14.4
[INFO] [stderr]    Compiling unicase v2.6.0
[INFO] [stderr]    Compiling tinyvec v1.1.1
[INFO] [stderr]    Compiling tracing-core v0.1.17
[INFO] [stderr]    Compiling tokio v1.1.1
[INFO] [stderr]    Compiling indexmap v1.6.1
[INFO] [stderr]    Compiling block-padding v0.1.5
[INFO] [stderr]    Compiling form_urlencoded v1.0.0
[INFO] [stderr]    Compiling rdkafka-sys v3.0.0+1.6.0
[INFO] [stderr]    Compiling want v0.3.0
[INFO] [stderr]    Compiling tracing v0.1.23
[INFO] [stderr]    Compiling twoway v0.1.8
[INFO] [stderr]    Compiling buf_redux v0.8.4
[INFO] [stderr]    Compiling aho-corasick v0.7.15
[INFO] [stderr]    Compiling quote v1.0.8
[INFO] [stderr]    Compiling unicode-normalization v0.1.16
[INFO] [stderr]    Compiling parking_lot_core v0.8.2
[INFO] [stderr]    Compiling num_cpus v1.13.0
[INFO] [stderr]    Compiling mio v0.7.7
[INFO] [stderr]    Compiling signal-hook-registry v1.3.0
[INFO] [stderr]    Compiling socket2 v0.3.19
[INFO] [stderr]    Compiling time v0.1.43
[INFO] [stderr]    Compiling atty v0.2.14
[INFO] [stderr]    Compiling libz-sys v1.1.2
[INFO] [stderr]    Compiling mime_guess v2.0.3
[INFO] [stderr]    Compiling rand_core v0.6.1
[INFO] [stderr]    Compiling parking_lot v0.11.1
[INFO] [stderr]    Compiling rand_core v0.5.1
[INFO] [stderr]    Compiling generic-array v0.12.3
[INFO] [stderr]    Compiling http-body v0.4.0
[INFO] [stderr]    Compiling headers-core v0.2.0
[INFO] [stderr]    Compiling idna v0.2.1
[INFO] [stderr]    Compiling rand_chacha v0.3.0
[INFO] [stderr]    Compiling regex v1.4.3
[INFO] [stderr]    Compiling rand_chacha v0.2.2
[INFO] [stderr]    Compiling digest v0.8.1
[INFO] [stderr]    Compiling block-buffer v0.7.3
[INFO] [stderr]    Compiling sha-1 v0.8.2
[INFO] [stderr]    Compiling rand v0.8.3
[INFO] [stderr]    Compiling rand v0.7.3
[INFO] [stderr]    Compiling digest v0.9.0
[INFO] [stderr]    Compiling block-buffer v0.9.0
[INFO] [stderr]    Compiling headers v0.3.3
[INFO] [stderr]    Compiling sha-1 v0.9.3
[INFO] [stderr]    Compiling url v2.2.0
[INFO] [stderr]    Compiling env_logger v0.8.2
[INFO] [stderr]    Compiling tungstenite v0.12.0
[INFO] [stderr]    Compiling tempfile v3.2.0
[INFO] [stderr]    Compiling multipart v0.17.1
[INFO] [stderr]    Compiling tokio-macros v1.0.0
[INFO] [stderr]    Compiling futures-macro v0.3.12
[INFO] [stderr]    Compiling pin-project-internal v1.0.5
[INFO] [stderr]    Compiling derivative v2.2.0
[INFO] [stderr]    Compiling futures-util v0.3.12
[INFO] [stderr]    Compiling pin-project v1.0.5
[INFO] [stderr]    Compiling pin-project v0.4.27
[INFO] [stderr]    Compiling tracing-futures v0.2.4
[INFO] [stderr]    Compiling toml v0.5.8
[INFO] [stderr]    Compiling serde_urlencoded v0.7.0
[INFO] [stderr]    Compiling uuid v0.8.2
[INFO] [stderr]    Compiling futures-executor v0.3.12
[INFO] [stderr]    Compiling futures v0.3.12
[INFO] [stderr]    Compiling proc-macro-crate v0.1.5
[INFO] [stderr]    Compiling num_enum_derive v0.5.1
[INFO] [stderr]    Compiling tokio-util v0.6.3
[INFO] [stderr]    Compiling tokio-tungstenite v0.13.0
[INFO] [stderr]    Compiling tokio-stream v0.1.2
[INFO] [stderr]    Compiling h2 v0.3.0
[INFO] [stderr]    Compiling num_enum v0.5.1
[INFO] [stderr]    Compiling rdkafka v0.25.0
[INFO] [stderr]    Compiling hyper v0.14.2
[INFO] [stderr]    Compiling warp v0.3.0
[INFO] [stderr]    Compiling with-kafka v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] error: internal compiler error: no errors encountered even though `delay_span_bug` issued
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: internal compiler error: broken MIR in DropGlue(DefId(2:2767 ~ core[87f6]::ptr::drop_in_place), Some(tokio::runtime::task::core::Stage<warp::hyper::server::conn::spawn_all::NewSvcTask<warp::hyper::server::conn::AddrStream, futures_util::future::ready::Ready<std::result::Result<warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, std::convert::Infallible>>, warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, warp::hyper::common::exec::Exec, warp::hyper::server::conn::spawn_all::NoopWatcher>>)) (after pass PhaseChange-Runtime(Optimized)) at bb3[0]:
[INFO] [stdout]                                 Field projection `((*_1) as Finished).field[0]` specified type `std::result::Result<(), tokio::task::JoinError>`, but actual type is std::result::Result<<warp::hyper::server::conn::spawn_all::NewSvcTask<warp::hyper::server::conn::AddrStream, futures_util::future::ready::Ready<std::result::Result<warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, std::convert::Infallible>>, warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, warp::hyper::common::exec::Exec, warp::hyper::server::conn::spawn_all::NoopWatcher> as warp::Future>::Output, tokio::task::JoinError>
[INFO] [stdout]   |
[INFO] [stdout]   = note: delayed at compiler/rustc_const_eval/src/transform/validate.rs:128:36
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] thread 'rustc' panicked at 'Box<dyn Any>', compiler/rustc_errors/src/lib.rs:1494:13
[INFO] [stdout] error: internal compiler error: broken MIR in DropGlue(DefId(2:2767 ~ core[87f6]::ptr::drop_in_place), Some(warp::hyper::server::conn::spawn_all::State<warp::hyper::server::conn::AddrStream, futures_util::future::ready::Ready<std::result::Result<warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, std::convert::Infallible>>, warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, warp::hyper::common::exec::Exec, warp::hyper::server::conn::spawn_all::NoopWatcher>)) (after pass PhaseChange-Runtime(Optimized)) at bb3[0]:
[INFO] [stdout]                                 Field projection `((*_1) as Connected).field[0]` specified type `warp::hyper::server::conn::upgrades::UpgradeableConnection<warp::hyper::server::conn::AddrStream, warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, warp::hyper::common::exec::Exec>`, but actual type is <warp::hyper::server::conn::spawn_all::NoopWatcher as warp::hyper::server::conn::spawn_all::Watcher<warp::hyper::server::conn::AddrStream, warp::hyper::service::util::ServiceFn<[closure@warp::Server<warp::filter::or::Or<warp::filter::or::Or<warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::path::Exact<warp::path::internal::Opaque<&str>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::post::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(inputs_schema::ValueInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::create_value}>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::update_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::put::{closure#0}]>::{closure#0}]>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::FilterFn<[closure@warp::body::is_content_type<warp::body::Json>::{closure#0}]>, warp::filter::and_then::AndThen<warp::filter::FilterFn<[closure@warp::filter::filter_fn_one<[closure@warp::body::body::{closure#0}], futures_util::future::ready::Ready<std::result::Result<warp::hyper::Body, warp::Rejection>>>::{closure#0}]>, [closure@warp::body::bytes::{closure#0}]>>, [closure@warp::body::json<inputs_schema::ValueOperationInput>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:69:21: 69:28]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:73:21: 73:28]>>, fn(uuid::Uuid, inputs_schema::ValueOperationInput, std::sync::Arc<tokio::sync::Mutex<rdkafka::producer::FutureProducer>>, config::Config) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {commands::update_value}>>, warp::filter::and_then::AndThen<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filter::and::And<warp::filters::any::Any, warp::path::Exact<warp::path::internal::Opaque<api::query_value::__StaticPath>>>, warp::filter::FilterFn<[closure@warp::path::filter_segment<[closure@warp::path::param<uuid::Uuid>::{closure#0}], (uuid::Uuid,)>::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::path::end::{closure#0}]>>, warp::filter::FilterFn<[closure@warp::filters::method::method_is<[closure@warp::get::{closure#0}]>::{closure#0}]>>, warp::filter::map::Map<warp::filters::any::Any, [closure@src/api.rs:77:21: 77:28]>>, fn(uuid::Uuid, std::sync::Arc<tokio::sync::Mutex<std::collections::HashMap<uuid::Uuid, f64>>>) -> impl warp::Future<Output = std::result::Result<impl warp::Reply, std::convert::Infallible>> {queries::get_value}>>>::bind_ephemeral<([u8; 4], u16)>::{closure#1}::{closure#0}::{closure#0}], warp::hyper::Body>, warp::hyper::common::exec::Exec>>::Future
[INFO] [stdout]   |
[INFO] [stdout]   = note: delayed at compiler/rustc_const_eval/src/transform/validate.rs:128:36
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr] stack backtrace:
[INFO] [stderr]    0:     0x7fb050b91210 - std::backtrace_rs::backtrace::libunwind::trace::h0635bbcc15f1a527
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/../../backtrace/src/backtrace/mod.rs:66:5
[INFO] [stderr]    1:     0x7fb050b91210 - std::backtrace_rs::backtrace::trace_unsynchronized::h2f139649c4717994
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/../../backtrace/src/backtrace/mod.rs:66:5
[INFO] [stderr]    2:     0x7fb050b91210 - std::sys_common::backtrace::_print_fmt::h1bfd64239328f990
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/sys_common/backtrace.rs:66:5
[INFO] [stderr]    3:     0x7fb050b91210 - <std::sys_common::backtrace::_print::DisplayBacktrace as core::fmt::Display>::fmt::h0228dc1410a56233
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/sys_common/backtrace.rs:45:22
[INFO] [stderr]    4:     0x7fb050bec02e - core::fmt::write::hceb37e40129b2ef6
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/core/src/fmt/mod.rs:1202:17
[INFO] [stderr]    5:     0x7fb050b81ad5 - std::io::Write::write_fmt::h7aef09b2f8dd6912
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/io/mod.rs:1679:15
[INFO] [stderr]    6:     0x7fb050b93e63 - std::sys_common::backtrace::_print::h9317a39a27ffc158
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/sys_common/backtrace.rs:48:5
[INFO] [stderr]    7:     0x7fb050b93e63 - std::sys_common::backtrace::print::h3f862bf30220d547
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/sys_common/backtrace.rs:35:9
[INFO] [stderr]    8:     0x7fb050b93e63 - std::panicking::default_hook::{{closure}}::h5f1809c5cfd4c61f
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/panicking.rs:295:22
[INFO] [stderr]    9:     0x7fb050b93b4f - std::panicking::default_hook::h48ae03b43c4da387
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/panicking.rs:314:9
[INFO] [stderr]   10:     0x7fb05340c461 - <rustc_driver[d785e9c303ecd8ca]::DEFAULT_HOOK::{closure#0}::{closure#0} as core[87f6064f357e42c2]::ops::function::FnOnce<(&core[87f6064f357e42c2]::panic::panic_info::PanicInfo,)>>::call_once::{shim:vtable#0}
[INFO] [stderr]   11:     0x7fb050b9469d - std::panicking::rust_panic_with_hook::h064155defabdfb6a
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/panicking.rs:702:17
[INFO] [stderr]   12:     0x7fb054553f21 - std[2aca39d6cbfe9e59]::panicking::begin_panic::<rustc_errors[7468fe47648b8434]::ExplicitBug>::{closure#0}
[INFO] [stderr]   13:     0x7fb054553a76 - std[2aca39d6cbfe9e59]::sys_common::backtrace::__rust_end_short_backtrace::<std[2aca39d6cbfe9e59]::panicking::begin_panic<rustc_errors[7468fe47648b8434]::ExplicitBug>::{closure#0}, !>
[INFO] [stderr]   14:     0x7fb0545535e6 - std[2aca39d6cbfe9e59]::panicking::begin_panic::<rustc_errors[7468fe47648b8434]::ExplicitBug>
[INFO] [stderr]   15:     0x7fb054556086 - std[2aca39d6cbfe9e59]::panic::panic_any::<rustc_errors[7468fe47648b8434]::ExplicitBug>
[INFO] [stderr]   16:     0x7fb052f67538 - <rustc_errors[7468fe47648b8434]::HandlerInner as core[87f6064f357e42c2]::ops::drop::Drop>::drop
[INFO] [stderr]   17:     0x7fb052204f98 - core[87f6064f357e42c2]::ptr::drop_in_place::<rustc_session[6075461f51ce8fa3]::parse::ParseSess>
[INFO] [stderr]   18:     0x7fb0521c3318 - <alloc[70b5d75d5e7e3937]::rc::Rc<rustc_session[6075461f51ce8fa3]::session::Session> as core[87f6064f357e42c2]::ops::drop::Drop>::drop
[INFO] [stderr]   19:     0x7fb0521c02cd - core[87f6064f357e42c2]::ptr::drop_in_place::<rustc_interface[4ffcd4abddbf64f2]::interface::Compiler>
[INFO] [stderr]   20:     0x7fb0521bdaff - rustc_interface[4ffcd4abddbf64f2]::interface::create_compiler_and_run::<core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>, rustc_driver[d785e9c303ecd8ca]::run_compiler::{closure#1}>
[INFO] [stderr]   21:     0x7fb0521bc011 - <scoped_tls[23c189ccdd19639]::ScopedKey<rustc_span[fe001c2be11f5545]::SessionGlobals>>::set::<rustc_interface[4ffcd4abddbf64f2]::interface::run_compiler<core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>, rustc_driver[d785e9c303ecd8ca]::run_compiler::{closure#1}>::{closure#0}, core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>>
[INFO] [stderr]   22:     0x7fb0521bbcff - std[2aca39d6cbfe9e59]::sys_common::backtrace::__rust_begin_short_backtrace::<rustc_interface[4ffcd4abddbf64f2]::util::run_in_thread_pool_with_globals<rustc_interface[4ffcd4abddbf64f2]::interface::run_compiler<core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>, rustc_driver[d785e9c303ecd8ca]::run_compiler::{closure#1}>::{closure#0}, core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>>::{closure#0}, core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>>
[INFO] [stderr]   23:     0x7fb053282e89 - <<std[2aca39d6cbfe9e59]::thread::Builder>::spawn_unchecked_<rustc_interface[4ffcd4abddbf64f2]::util::run_in_thread_pool_with_globals<rustc_interface[4ffcd4abddbf64f2]::interface::run_compiler<core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>, rustc_driver[d785e9c303ecd8ca]::run_compiler::{closure#1}>::{closure#0}, core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>>::{closure#0}, core[87f6064f357e42c2]::result::Result<(), rustc_errors[7468fe47648b8434]::ErrorGuaranteed>>::{closure#1} as core[87f6064f357e42c2]::ops::function::FnOnce<()>>::call_once::{shim:vtable#0}
[INFO] [stderr]   24:     0x7fb050b9e4f3 - <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once::h3998462ded511e97
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/alloc/src/boxed.rs:1940:9
[INFO] [stderr]   25:     0x7fb050b9e4f3 - <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once::hb68442c5b53e403f
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/alloc/src/boxed.rs:1940:9
[INFO] [stderr]   26:     0x7fb050b9e4f3 - std::sys::unix::thread::Thread::new::thread_start::h9c65d60d9d9c7be4
[INFO] [stderr]                                at /rustc/b755f8b9936d084e0363ce6b393c7e444a37080e/library/std/src/sys/unix/thread.rs:108:17
[INFO] [stderr]   27:     0x7fb050a4f609 - start_thread
[INFO] [stderr]   28:     0x7fb050972133 - clone
[INFO] [stderr]   29:                0x0 - <unknown>
[INFO] [stderr] 
[INFO] [stderr] note: the compiler unexpectedly panicked. this is a bug.
[INFO] [stderr] 
[INFO] [stderr] note: we would appreciate a bug report: https://github.com/rust-lang/rust/issues/new?labels=C-bug%2C+I-ICE%2C+T-compiler&template=ice.md
[INFO] [stderr] 
[INFO] [stderr] note: rustc 1.65.0-nightly (b755f8b99 2022-09-07) running on x86_64-unknown-linux-gnu
[INFO] [stderr] 
[INFO] [stderr] note: compiler flags: --crate-type bin -C embed-bitcode=no -C debuginfo=2
[INFO] [stderr] 
[INFO] [stderr] note: some of the compiler flags provided by cargo are hidden
[INFO] [stderr] 
[INFO] [stderr] query stack during panic:
[INFO] [stderr] end of query stack
[INFO] [stderr] error: could not compile `with-kafka`
[INFO] running `Command { std: "docker" "inspect" "aed36d648867cbb3c34b5f5bcddea62e5555b07d1b6621bfc2b50d4ceec0a97c", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "aed36d648867cbb3c34b5f5bcddea62e5555b07d1b6621bfc2b50d4ceec0a97c", kill_on_drop: false }`
[INFO] [stdout] aed36d648867cbb3c34b5f5bcddea62e5555b07d1b6621bfc2b50d4ceec0a97c