[INFO] cloning repository https://github.com/jay-johnson/rust-kafka-threadpool [INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/jay-johnson/rust-kafka-threadpool" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fjay-johnson%2Frust-kafka-threadpool", kill_on_drop: false }` [INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fjay-johnson%2Frust-kafka-threadpool'... [INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }` [INFO] [stdout] ba3f57030ce9e57bef2ff791cf5af8e00ad51f04 [INFO] testing jay-johnson/rust-kafka-threadpool against try#a7ce54db9b096bd1098d07c645b489195a667c9f for pr-137940-2 [INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fjay-johnson%2Frust-kafka-threadpool" "/workspace/builds/worker-0-tc2/source", kill_on_drop: false }` [INFO] [stderr] Cloning into '/workspace/builds/worker-0-tc2/source'... [INFO] [stderr] done. [INFO] validating manifest of git repo https://github.com/jay-johnson/rust-kafka-threadpool on toolchain a7ce54db9b096bd1098d07c645b489195a667c9f [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+a7ce54db9b096bd1098d07c645b489195a667c9f" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking git repo https://github.com/jay-johnson/rust-kafka-threadpool [INFO] finished tweaking git repo https://github.com/jay-johnson/rust-kafka-threadpool [INFO] tweaked toml for git repo https://github.com/jay-johnson/rust-kafka-threadpool written to /workspace/builds/worker-0-tc2/source/Cargo.toml [INFO] crate git repo https://github.com/jay-johnson/rust-kafka-threadpool 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" "+a7ce54db9b096bd1098d07c645b489195a667c9f" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/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:1680c8fbd8dfb46fcd6d22e546df16ab0e007457dc29fcd9e987cdd5077fd1af" "/opt/rustwide/cargo-home/bin/cargo" "+a7ce54db9b096bd1098d07c645b489195a667c9f" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] a2b900924baf55ed56db6178338a016f256364977d9c9dd4554c228770f8cec4 [INFO] running `Command { std: "docker" "start" "-a" "a2b900924baf55ed56db6178338a016f256364977d9c9dd4554c228770f8cec4", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "a2b900924baf55ed56db6178338a016f256364977d9c9dd4554c228770f8cec4", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a2b900924baf55ed56db6178338a016f256364977d9c9dd4554c228770f8cec4", kill_on_drop: false }` [INFO] [stdout] a2b900924baf55ed56db6178338a016f256364977d9c9dd4554c228770f8cec4 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/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:1680c8fbd8dfb46fcd6d22e546df16ab0e007457dc29fcd9e987cdd5077fd1af" "/opt/rustwide/cargo-home/bin/cargo" "+a7ce54db9b096bd1098d07c645b489195a667c9f" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 8f8717b442f4932188754b49741b553d8690ef53ffbd22e65acd4c4dda875392 [INFO] running `Command { std: "docker" "start" "-a" "8f8717b442f4932188754b49741b553d8690ef53ffbd22e65acd4c4dda875392", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.43 [INFO] [stderr] Compiling quote v1.0.21 [INFO] [stderr] Compiling unicode-ident v1.0.4 [INFO] [stderr] Compiling syn v1.0.100 [INFO] [stderr] Compiling cc v1.0.73 [INFO] [stderr] Compiling libc v0.2.133 [INFO] [stderr] Compiling memchr v2.5.0 [INFO] [stderr] Compiling serde v1.0.144 [INFO] [stderr] Compiling futures-core v0.3.24 [INFO] [stderr] Compiling thiserror v1.0.35 [INFO] [stderr] Compiling futures-task v0.3.24 [INFO] [stderr] Compiling futures-channel v0.3.24 [INFO] [stderr] Compiling once_cell v1.14.0 [INFO] [stderr] Compiling log v0.4.17 [INFO] [stderr] Compiling futures-util v0.3.24 [INFO] [stderr] Compiling futures-sink v0.3.24 [INFO] [stderr] Compiling serde_derive v1.0.144 [INFO] [stderr] Compiling futures-io v0.3.24 [INFO] [stderr] Compiling tokio v1.21.1 [INFO] [stderr] Compiling serde_json v1.0.85 [INFO] [stderr] Compiling regex-syntax v0.6.27 [INFO] [stderr] Compiling quick-error v1.2.3 [INFO] [stderr] Compiling humantime v1.3.0 [INFO] [stderr] Compiling ryu v1.0.11 [INFO] [stderr] Compiling itoa v1.0.3 [INFO] [stderr] Compiling openssl-src v111.22.0+1.1.1q [INFO] [stderr] Compiling cmake v0.1.48 [INFO] [stderr] Compiling libz-sys v1.1.8 [INFO] [stderr] Compiling openssl-sys v0.9.75 [INFO] [stderr] Compiling rdkafka-sys v4.2.0+1.8.2 [INFO] [stderr] Compiling aho-corasick v0.7.19 [INFO] [stderr] Compiling atty v0.2.14 [INFO] [stderr] Compiling num_cpus v1.13.1 [INFO] [stderr] Compiling regex v1.6.0 [INFO] [stderr] Compiling toml v0.5.9 [INFO] [stderr] Compiling env_logger v0.7.1 [INFO] [stderr] Compiling pretty_env_logger v0.4.0 [INFO] [stderr] Compiling thiserror-impl v1.0.35 [INFO] [stderr] Compiling futures-macro v0.3.24 [INFO] [stderr] Compiling tokio-macros v1.8.0 [INFO] [stderr] Compiling proc-macro-crate v1.2.1 [INFO] [stderr] Compiling num_enum_derive v0.5.7 [INFO] [stderr] Compiling num_enum v0.5.7 [INFO] [stderr] Compiling futures-executor v0.3.24 [INFO] [stderr] Compiling futures v0.3.24 [INFO] [stderr] Compiling rdkafka v0.28.0 [INFO] [stderr] Compiling kafka-threadpool v1.0.12 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 21s [INFO] running `Command { std: "docker" "inspect" "8f8717b442f4932188754b49741b553d8690ef53ffbd22e65acd4c4dda875392", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "8f8717b442f4932188754b49741b553d8690ef53ffbd22e65acd4c4dda875392", kill_on_drop: false }` [INFO] [stdout] 8f8717b442f4932188754b49741b553d8690ef53ffbd22e65acd4c4dda875392 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/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:1680c8fbd8dfb46fcd6d22e546df16ab0e007457dc29fcd9e987cdd5077fd1af" "/opt/rustwide/cargo-home/bin/cargo" "+a7ce54db9b096bd1098d07c645b489195a667c9f" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] ed6edd9e04ac7d665b173b6f680938771d8d2e0eeefe57c7db1cc880e76f2033 [INFO] running `Command { std: "docker" "start" "-a" "ed6edd9e04ac7d665b173b6f680938771d8d2e0eeefe57c7db1cc880e76f2033", kill_on_drop: false }` [INFO] [stderr] Compiling kafka-threadpool v1.0.12 (/opt/rustwide/workdir) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 1.14s [INFO] running `Command { std: "docker" "inspect" "ed6edd9e04ac7d665b173b6f680938771d8d2e0eeefe57c7db1cc880e76f2033", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "ed6edd9e04ac7d665b173b6f680938771d8d2e0eeefe57c7db1cc880e76f2033", kill_on_drop: false }` [INFO] [stdout] ed6edd9e04ac7d665b173b6f680938771d8d2e0eeefe57c7db1cc880e76f2033 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc2/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:1680c8fbd8dfb46fcd6d22e546df16ab0e007457dc29fcd9e987cdd5077fd1af" "/opt/rustwide/cargo-home/bin/cargo" "+a7ce54db9b096bd1098d07c645b489195a667c9f" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] c354aadbeb6e5943b6c7dff6c1c5020ef517050e23ca9dec0b4d6ee35467e021 [INFO] running `Command { std: "docker" "start" "-a" "c354aadbeb6e5943b6c7dff6c1c5020ef517050e23ca9dec0b4d6ee35467e021", kill_on_drop: false }` [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.08s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/kafka_threadpool-04ee9940e4c3f92d) [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] [stderr] Doc-tests kafka_threadpool [INFO] [stdout] [INFO] [stdout] running 8 tests [INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) ... FAILED [INFO] [stdout] test src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) ... FAILED [INFO] [stdout] test src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) ... FAILED [INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher (line 11) ... FAILED [INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) ... FAILED [INFO] [stdout] test src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) ... FAILED [INFO] [stdout] test src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) ... FAILED [INFO] [stdout] test src/api/kafka_publish_message.rs - api::kafka_publish_message::KafkaPublishMessage::new_from (line 69) ... ok [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] [INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `my_threadpool` in this scope [INFO] [stdout] --> src/kafka_publisher.rs:231:1 [INFO] [stdout] | [INFO] [stdout] 3 | my_threadpool.shutdown().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/kafka_publisher.rs:231:26 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_kafka_publisher_rs_230_0() { [INFO] [stdout] | ----------------------------------------------- this is not `async` [INFO] [stdout] 3 | my_threadpool.shutdown().await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) stdout ---- [INFO] [stdout] error: expected `;`, found `}` [INFO] [stdout] --> src/api/build_kafka_client_config.rs:36:71 [INFO] [stdout] | [INFO] [stdout] 6 | let kafka_config: KafkaClientConfig = build_kafka_client_config("ktp") [INFO] [stdout] | ^ help: add `;` here [INFO] [stdout] 7 | } _doctest_main_src_api_build_kafka_client_config_rs_33_0() } [INFO] [stdout] | - unexpected token [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `kafka_threadpool::config::kafka_client_config::build_kafka_client_config` [INFO] [stdout] --> src/api/build_kafka_client_config.rs:35:5 [INFO] [stdout] | [INFO] [stdout] 5 | use kafka_threadpool::config::kafka_client_config::build_kafka_client_config; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `build_kafka_client_config` in `config::kafka_client_config` [INFO] [stdout] | [INFO] [stdout] help: consider importing this module instead [INFO] [stdout] | [INFO] [stdout] 5 - use kafka_threadpool::config::kafka_client_config::build_kafka_client_config; [INFO] [stdout] 5 + use kafka_threadpool::api::build_kafka_client_config; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `KafkaClientConfig` in this scope [INFO] [stdout] --> src/api/build_kafka_client_config.rs:36:19 [INFO] [stdout] | [INFO] [stdout] 6 | let kafka_config: KafkaClientConfig = build_kafka_client_config("ktp") [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 + use kafka_threadpool::config::kafka_client_config::KafkaClientConfig; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error: aborting due to 3 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0412, E0432. [INFO] [stdout] For more information about an error, try `rustc --explain E0412`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) stdout ---- [INFO] [stdout] error[E0412]: cannot find type `KafkaPublishMessage` in this scope [INFO] [stdout] --> src/api/build_kafka_publish_message.rs:32:14 [INFO] [stdout] | [INFO] [stdout] 10 | let new_msg: KafkaPublishMessage = build_kafka_publish_message( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/workdir/src/api/kafka_publish_message_type.rs:20:1 [INFO] [stdout] | [INFO] [stdout] 20 | pub enum KafkaPublishMessageType { [INFO] [stdout] | -------------------------------- similarly named enum `KafkaPublishMessageType` defined here [INFO] [stdout] | [INFO] [stdout] help: an enum with a similar name exists [INFO] [stdout] | [INFO] [stdout] 10 | let new_msg: KafkaPublishMessageType = build_kafka_publish_message( [INFO] [stdout] | ++++ [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 2 + use kafka_threadpool::api::kafka_publish_message::KafkaPublishMessage; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0412`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher (line 11) stdout ---- [INFO] [stdout] error[E0425]: cannot find value `my_kafka_publisher` in this scope [INFO] [stdout] --> src/kafka_publisher.rs:12:1 [INFO] [stdout] | [INFO] [stdout] 3 | my_kafka_publisher.shutdown().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/kafka_publisher.rs:12:31 [INFO] [stdout] | [INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_kafka_publisher_rs_11_0() { [INFO] [stdout] | ---------------------------------------------- this is not `async` [INFO] [stdout] 3 | my_kafka_publisher.shutdown().await.unwrap(); [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0425, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0425`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) stdout ---- [INFO] [stdout] error[E0432]: unresolved import `crate::kafka_publisher` [INFO] [stdout] --> src/kafka_publisher.rs:57:12 [INFO] [stdout] | [INFO] [stdout] 3 | use crate::kafka_publisher::KafkaPublisher; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | unresolved import [INFO] [stdout] | help: a similar path exists: `kafka_threadpool::kafka_publisher` [INFO] [stdout] [INFO] [stdout] error: aborting due to 1 previous error [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0432`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) stdout ---- [INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks [INFO] [stdout] --> src/start_threadpool.rs:24:51 [INFO] [stdout] | [INFO] [stdout] 4 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_start_threadpool_rs_20_0() { [INFO] [stdout] | ----------------------------------------------- this is not `async` [INFO] [stdout] ... [INFO] [stdout] 7 | let kafka_publisher = start_threadpool(log_label).await; [INFO] [stdout] | ^^^^^ only allowed inside `async` functions and blocks [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/start_threadpool.rs:24:40 [INFO] [stdout] | [INFO] [stdout] 7 | let kafka_publisher = start_threadpool(log_label).await; [INFO] [stdout] | ---------------- ^^^^^^^^^ expected `Option<&str>`, found `&str` [INFO] [stdout] | | [INFO] [stdout] | arguments to this function are incorrect [INFO] [stdout] | [INFO] [stdout] = note: expected enum `Option<&str>` [INFO] [stdout] found reference `&str` [INFO] [stdout] note: function defined here [INFO] [stdout] --> /opt/rustwide/workdir/src/start_threadpool.rs:26:14 [INFO] [stdout] | [INFO] [stdout] 26 | pub async fn start_threadpool(label: Option<&str>) -> KafkaPublisher { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] help: try wrapping the expression in `Some` [INFO] [stdout] | [INFO] [stdout] 7 | let kafka_publisher = start_threadpool(Some(log_label)).await; [INFO] [stdout] | +++++ + [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0308, E0728. [INFO] [stdout] For more information about an error, try `rustc --explain E0308`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] ---- src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) stdout ---- [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/pool/start_threads_from_config.rs:26:55 [INFO] [stdout] | [INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config) { [INFO] [stdout] | ------------------------- ^^^^^^^ expected `KafkaClientConfig`, found `&KafkaClientConfig` [INFO] [stdout] | | [INFO] [stdout] | arguments to this function are incorrect [INFO] [stdout] | [INFO] [stdout] note: function defined here [INFO] [stdout] --> /opt/rustwide/workdir/src/pool/start_threads_from_config.rs:32:14 [INFO] [stdout] | [INFO] [stdout] 32 | pub async fn start_threads_from_config( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] help: consider removing the borrow [INFO] [stdout] | [INFO] [stdout] 8 - let kafka_publisher = match start_threads_from_config(&config) { [INFO] [stdout] 8 + let kafka_publisher = match start_threads_from_config(config) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/pool/start_threads_from_config.rs:27:5 [INFO] [stdout] | [INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config) { [INFO] [stdout] | ---------------------------------- this expression has type `impl Future>` [INFO] [stdout] 9 | Ok(kp) => kp, [INFO] [stdout] | ^^^^^^ expected future, found `Result<_, _>` [INFO] [stdout] | [INFO] [stdout] = note: expected opaque type `impl Future>` [INFO] [stdout] found enum `Result<_, _>` [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/pool/start_threads_from_config.rs:28:5 [INFO] [stdout] | [INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config) { [INFO] [stdout] | ---------------------------------- this expression has type `impl Future>` [INFO] [stdout] 9 | Ok(kp) => kp, [INFO] [stdout] 10 | Err(e) => panic!("failed to start threads with err={e}") [INFO] [stdout] | ^^^^^^ expected future, found `Result<_, _>` [INFO] [stdout] | [INFO] [stdout] = note: expected opaque type `impl Future>` [INFO] [stdout] found enum `Result<_, _>` [INFO] [stdout] [INFO] [stdout] error: aborting due to 3 previous errors [INFO] [stdout] [INFO] [stdout] For more information about this error, try `rustc --explain E0308`. [INFO] [stdout] Couldn't compile the test. [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) [INFO] [stdout] src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) [INFO] [stdout] src/kafka_publisher.rs - kafka_publisher (line 11) [INFO] [stdout] src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) [INFO] [stdout] src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) [INFO] [stdout] src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) [INFO] [stdout] src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) [INFO] [stdout] [INFO] [stdout] test result: FAILED. 1 passed; 7 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.65s [INFO] [stdout] [INFO] [stderr] error: doctest failed, to rerun pass `--doc` [INFO] running `Command { std: "docker" "inspect" "c354aadbeb6e5943b6c7dff6c1c5020ef517050e23ca9dec0b4d6ee35467e021", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c354aadbeb6e5943b6c7dff6c1c5020ef517050e23ca9dec0b4d6ee35467e021", kill_on_drop: false }` [INFO] [stdout] c354aadbeb6e5943b6c7dff6c1c5020ef517050e23ca9dec0b4d6ee35467e021