[INFO] fetching crate apalis-core 1.0.0-rc.7... [INFO] checking apalis-core-1.0.0-rc.7 against try#b6bca0d7327839b5e3f7a7779947cb9113d08917+rustflags=-Zstrict-projection-item-bounds for 150662-leaf [INFO] extracting crate apalis-core 1.0.0-rc.7 into /workspace/builds/worker-4-tc2/source [INFO] started tweaking crates.io crate apalis-core 1.0.0-rc.7 [INFO] finished tweaking crates.io crate apalis-core 1.0.0-rc.7 [INFO] tweaked toml for crates.io crate apalis-core 1.0.0-rc.7 written to /workspace/builds/worker-4-tc2/source/Cargo.toml [INFO] validating manifest of crates.io crate apalis-core 1.0.0-rc.7 on toolchain b6bca0d7327839b5e3f7a7779947cb9113d08917 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b6bca0d7327839b5e3f7a7779947cb9113d08917" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate apalis-core 1.0.0-rc.7 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" "+b6bca0d7327839b5e3f7a7779947cb9113d08917" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+b6bca0d7327839b5e3f7a7779947cb9113d08917" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 96ca6ff9b5dda2f2f2a9587b7d38a4f092aae855cd18c6ff26c32a3f38a8adcf [INFO] running `Command { std: "docker" "start" "-a" "96ca6ff9b5dda2f2f2a9587b7d38a4f092aae855cd18c6ff26c32a3f38a8adcf", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "96ca6ff9b5dda2f2f2a9587b7d38a4f092aae855cd18c6ff26c32a3f38a8adcf", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "96ca6ff9b5dda2f2f2a9587b7d38a4f092aae855cd18c6ff26c32a3f38a8adcf", kill_on_drop: false }` [INFO] [stdout] 96ca6ff9b5dda2f2f2a9587b7d38a4f092aae855cd18c6ff26c32a3f38a8adcf [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4-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 -Zstrict-projection-item-bounds" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+b6bca0d7327839b5e3f7a7779947cb9113d08917" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 3be737738d3ec94d37a25f119189c72ec6ecaed2c56d97e4b2d0ea16f970a120 [INFO] running `Command { std: "docker" "start" "-a" "3be737738d3ec94d37a25f119189c72ec6ecaed2c56d97e4b2d0ea16f970a120", kill_on_drop: false }` [INFO] [stderr] Checking futures-sink v0.3.32 [INFO] [stderr] Checking futures-core v0.3.32 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Checking tracing-core v0.1.36 [INFO] [stderr] Compiling thiserror v2.0.18 [INFO] [stderr] Checking slab v0.4.12 [INFO] [stderr] Compiling syn v2.0.117 [INFO] [stderr] Checking mio v1.1.1 [INFO] [stderr] Checking hashbrown v0.16.1 [INFO] [stderr] Checking futures-channel v0.3.32 [INFO] [stderr] Checking futures-timer v3.0.3 [INFO] [stderr] Checking tracing v0.1.44 [INFO] [stderr] Checking indexmap v2.13.0 [INFO] [stderr] Checking hdrhistogram v7.5.4 [INFO] [stderr] Compiling futures-macro v0.3.32 [INFO] [stderr] Compiling tokio-macros v2.6.1 [INFO] [stderr] Compiling pin-project-internal v1.1.11 [INFO] [stderr] Compiling thiserror-impl v2.0.18 [INFO] [stderr] Checking tokio v1.50.0 [INFO] [stderr] Checking futures-util v0.3.32 [INFO] [stderr] Checking pin-project v1.1.11 [INFO] [stderr] Checking apalis-core v1.0.0-rc.7 (/opt/rustwide/workdir) [INFO] [stderr] Checking tokio-util v0.7.18 [INFO] [stderr] Checking tower v0.5.3 [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:72:23 [INFO] [stdout] | [INFO] [stdout] 72 | let encoded = C::encode(&task).map_err(|e| TaskSinkError::CodecError(e.into()))?; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:72:23 [INFO] [stdout] | [INFO] [stdout] 72 | let encoded = C::encode(&task).map_err(|e| TaskSinkError::CodecError(e.into()))?; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: SinkExt>::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:73:19 [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded)).await?; [INFO] [stdout] | ---- ^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = note: required for `S` to implement `SinkExt::Compact, ::Context, ::IdType>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-12518757602045039666.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/backend/sink.rs:73:29 [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded)).await?; [INFO] [stdout] | --------- ^^^^^^^ expected `Codec::Compact`, found `BackendExt::Compact` [INFO] [stdout] | | [INFO] [stdout] | arguments to this function are incorrect [INFO] [stdout] | [INFO] [stdout] = note: expected associated type `>::Compact` [INFO] [stdout] found associated type `::Compact` [INFO] [stdout] = note: an associated type was expected, but a different one was found [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/task/mod.rs:201:12 [INFO] [stdout] | [INFO] [stdout] 201 | pub fn new(args: Args) -> Self [INFO] [stdout] | ^^^ ---------- [INFO] [stdout] help: call `Into::into` on this expression to convert `::Compact` into `>::Compact` [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded.into())).await?; [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:73:39 [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded)).await?; [INFO] [stdout] | ^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] = note: required for `Send<'_, S, Task<::Compact, ..., ...>>` to implement `futures_util::Future` [INFO] [stdout] = note: required for `Send<'_, S, Task<::Compact, ..., ...>>` to implement `std::future::IntoFuture` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] help: remove the `.await` [INFO] [stdout] | [INFO] [stdout] 73 - self.send(Task::new(encoded)).await?; [INFO] [stdout] 73 + self.send(Task::new(encoded))?; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:70:45 [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:70:45 [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:83:34 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:83:34 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:83:17 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:83:17 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] | |______________^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] | |______________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] 85 | | .collect::, _>>()?; [INFO] [stdout] | |___________________________________________^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] 85 | | .collect::, _>>()?; [INFO] [stdout] | |___________________________________________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:86:14 [INFO] [stdout] | [INFO] [stdout] 86 | self.send_all(&mut stream::iter(tasks.into_iter().map(Ok))) [INFO] [stdout] | ^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `send_all` [INFO] [stdout] --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/futures-util-0.3.32/src/sink/mod.rs:65:26 [INFO] [stdout] | [INFO] [stdout] 65 | pub trait SinkExt: Sink { [INFO] [stdout] | ^^^^^^^^^^ required by this bound in `SinkExt::send_all` [INFO] [stdout] ... [INFO] [stdout] 252 | fn send_all<'a, St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> [INFO] [stdout] | -------- required by a bound in this associated function [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:87:14 [INFO] [stdout] | [INFO] [stdout] 87 | .await?; [INFO] [stdout] | ^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] = note: required for `SendAll<'_, S, Iter>, ...>>>` to implement `futures_util::Future` [INFO] [stdout] = note: required for `SendAll<'_, S, Iter>, ...>>>` to implement `std::future::IntoFuture` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] help: remove the `.await` [INFO] [stdout] | [INFO] [stdout] 87 - .await?; [INFO] [stdout] 87 + ?; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:77:56 [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:77:56 [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0271]: type mismatch resolving ` as Stream>::Item == Result<..., ...>` [INFO] [stdout] --> src/backend/sink.rs:87:14 [INFO] [stdout] | [INFO] [stdout] 87 | .await?; [INFO] [stdout] | ^^^^^ expected `BackendExt::Compact`, found `Codec::Compact` [INFO] [stdout] | [INFO] [stdout] = note: expected enum `Result::Compact, _, _>, _>` [INFO] [stdout] found enum `Result>::Compact, _, _>, _>` [INFO] [stdout] = note: required for `SendAll<'_, S, Iter>, ...>>>` to implement `futures_util::Future` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-3875451953190360683.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:95:14 [INFO] [stdout] | [INFO] [stdout] 95 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] = note: required for `&mut S` to implement `Sink>::Compact, ::Context, ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:95:9 [INFO] [stdout] | [INFO] [stdout] 95 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:95:9 [INFO] [stdout] | [INFO] [stdout] 95 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: the method `send_all` exists for struct `SinkMapErr<&mut S, {closure@src/backend/sink.rs:95:27: 95:30}>`, but its trait bounds were not satisfied [INFO] [stdout] --> src/backend/sink.rs:96:14 [INFO] [stdout] | [INFO] [stdout] 95 | / self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] 96 | | .send_all(&mut tasks.map(Task::new).map(|task| { [INFO] [stdout] | | -^^^^^^^^ method cannot be called due to unsatisfied trait bounds [INFO] [stdout] | |_____________| [INFO] [stdout] | [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/pin-project-lite-0.2.17/src/lib.rs:745:9 [INFO] [stdout] | [INFO] [stdout] 745 | / $vis struct $ident $($def_generics)* [INFO] [stdout] 746 | | $(where [INFO] [stdout] 747 | | $($where_clause)*)? [INFO] [stdout] ... | [INFO] [stdout] 751 | | ),+ [INFO] [stdout] 752 | | } [INFO] [stdout] | |_________- doesn't satisfy `_: Sink<_>` or `_: SinkExt<_>` [INFO] [stdout] | [INFO] [stdout] = note: the following trait bounds were not satisfied: [INFO] [stdout] `SinkMapErr<&mut S, {closure@src/backend/sink.rs:95:27: 95:30}>: futures_util::Sink<_>` [INFO] [stdout] which is required by `SinkMapErr<&mut S, {closure@src/backend/sink.rs:95:27: 95:30}>: SinkExt<_>` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:97:34 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:97:34 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:97:17 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:97:17 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:96:28 [INFO] [stdout] | [INFO] [stdout] 96 | .send_all(&mut tasks.map(Task::new).map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 97 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 98 | | })) [INFO] [stdout] | |______________^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:96:28 [INFO] [stdout] | [INFO] [stdout] 96 | .send_all(&mut tasks.map(Task::new).map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 97 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 98 | | })) [INFO] [stdout] | |______________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:94:10 [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:94:10 [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:107:14 [INFO] [stdout] | [INFO] [stdout] 107 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] = note: required for `&mut S` to implement `Sink>::Compact, ::Context, ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:107:9 [INFO] [stdout] | [INFO] [stdout] 107 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:107:9 [INFO] [stdout] | [INFO] [stdout] 107 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: the method `send` exists for struct `SinkMapErr<&mut S, {closure@src/backend/sink.rs:107:27: 107:30}>`, but its trait bounds were not satisfied [INFO] [stdout] --> src/backend/sink.rs:108:14 [INFO] [stdout] | [INFO] [stdout] 107 | / self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] 108 | | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | | -^^^^ method cannot be called due to unsatisfied trait bounds [INFO] [stdout] | |_____________| [INFO] [stdout] | [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/pin-project-lite-0.2.17/src/lib.rs:745:9 [INFO] [stdout] | [INFO] [stdout] 745 | / $vis struct $ident $($def_generics)* [INFO] [stdout] 746 | | $(where [INFO] [stdout] 747 | | $($where_clause)*)? [INFO] [stdout] ... | [INFO] [stdout] 751 | | ),+ [INFO] [stdout] 752 | | } [INFO] [stdout] | |_________- doesn't satisfy `_: Sink<_>` or `_: SinkExt<_>` [INFO] [stdout] | [INFO] [stdout] = note: the following trait bounds were not satisfied: [INFO] [stdout] `SinkMapErr<&mut S, {closure@src/backend/sink.rs:107:27: 107:30}>: futures_util::Sink<_>` [INFO] [stdout] which is required by `SinkMapErr<&mut S, {closure@src/backend/sink.rs:107:27: 107:30}>: SinkExt<_>` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:108:36 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:108:36 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:108:19 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:108:19 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:105:10 [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:105:10 [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:117:14 [INFO] [stdout] | [INFO] [stdout] 117 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] = note: required for `&mut S` to implement `Sink>::Compact, ::Context, ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:117:9 [INFO] [stdout] | [INFO] [stdout] 117 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:117:9 [INFO] [stdout] | [INFO] [stdout] 117 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: the method `send_all` exists for struct `SinkMapErr<&mut S, {closure@src/backend/sink.rs:117:27: 117:30}>`, but its trait bounds were not satisfied [INFO] [stdout] --> src/backend/sink.rs:118:14 [INFO] [stdout] | [INFO] [stdout] 117 | / self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] 118 | | .send_all(&mut tasks.map(|task| { [INFO] [stdout] | | -^^^^^^^^ method cannot be called due to unsatisfied trait bounds [INFO] [stdout] | |_____________| [INFO] [stdout] | [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/pin-project-lite-0.2.17/src/lib.rs:745:9 [INFO] [stdout] | [INFO] [stdout] 745 | / $vis struct $ident $($def_generics)* [INFO] [stdout] 746 | | $(where [INFO] [stdout] 747 | | $($where_clause)*)? [INFO] [stdout] ... | [INFO] [stdout] 751 | | ),+ [INFO] [stdout] 752 | | } [INFO] [stdout] | |_________- doesn't satisfy `_: Sink<_>` or `_: SinkExt<_>` [INFO] [stdout] | [INFO] [stdout] = note: the following trait bounds were not satisfied: [INFO] [stdout] `SinkMapErr<&mut S, {closure@src/backend/sink.rs:117:27: 117:30}>: futures_util::Sink<_>` [INFO] [stdout] which is required by `SinkMapErr<&mut S, {closure@src/backend/sink.rs:117:27: 117:30}>: SinkExt<_>` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:119:34 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:119:34 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:119:17 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:119:17 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:118:28 [INFO] [stdout] | [INFO] [stdout] 118 | .send_all(&mut tasks.map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 119 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 120 | | })) [INFO] [stdout] | |______________^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:118:28 [INFO] [stdout] | [INFO] [stdout] 118 | .send_all(&mut tasks.map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 119 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 120 | | })) [INFO] [stdout] | |______________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:115:10 [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:115:10 [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:29:10 [INFO] [stdout] | [INFO] [stdout] 29 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:29:10 [INFO] [stdout] | [INFO] [stdout] 29 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:35:10 [INFO] [stdout] | [INFO] [stdout] 35 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:35:10 [INFO] [stdout] | [INFO] [stdout] 35 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:41:10 [INFO] [stdout] | [INFO] [stdout] 41 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:41:10 [INFO] [stdout] | [INFO] [stdout] 41 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:47:10 [INFO] [stdout] | [INFO] [stdout] 47 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:47:10 [INFO] [stdout] | [INFO] [stdout] 47 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:53:10 [INFO] [stdout] | [INFO] [stdout] 53 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:53:10 [INFO] [stdout] | [INFO] [stdout] 53 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:58:60 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-e31e14392a99353f.long-type-5361897843878093446.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: backend::sink::TaskSink` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:56:40 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^ the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] | [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:56:40 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0271, E0277, E0308, E0599. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0271`. [INFO] [stdout] [INFO] [stderr] error: could not compile `apalis-core` (lib) due to 73 previous errors [INFO] [stderr] warning: build failed, waiting for other jobs to finish... [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:72:23 [INFO] [stdout] | [INFO] [stdout] 72 | let encoded = C::encode(&task).map_err(|e| TaskSinkError::CodecError(e.into()))?; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:72:23 [INFO] [stdout] | [INFO] [stdout] 72 | let encoded = C::encode(&task).map_err(|e| TaskSinkError::CodecError(e.into()))?; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: SinkExt>::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:73:19 [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded)).await?; [INFO] [stdout] | ---- ^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: required for `S` to implement `SinkExt::Compact, ..., ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-15423862648097922086.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/backend/sink.rs:73:29 [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded)).await?; [INFO] [stdout] | --------- ^^^^^^^ expected `Codec::Compact`, found `BackendExt::Compact` [INFO] [stdout] | | [INFO] [stdout] | arguments to this function are incorrect [INFO] [stdout] | [INFO] [stdout] = note: expected associated type `>::Compact` [INFO] [stdout] found associated type `::Compact` [INFO] [stdout] = note: an associated type was expected, but a different one was found [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/task/mod.rs:201:12 [INFO] [stdout] | [INFO] [stdout] 201 | pub fn new(args: Args) -> Self [INFO] [stdout] | ^^^ ---------- [INFO] [stdout] help: call `Into::into` on this expression to convert `::Compact` into `>::Compact` [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded.into())).await?; [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:73:39 [INFO] [stdout] | [INFO] [stdout] 73 | self.send(Task::new(encoded)).await?; [INFO] [stdout] | ^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: required for `Send<'_, S, Task<::Compact, ..., ...>>` to implement `futures_util::Future` [INFO] [stdout] = note: required for `Send<'_, S, Task<::Compact, ..., ...>>` to implement `std::future::IntoFuture` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] help: remove the `.await` [INFO] [stdout] | [INFO] [stdout] 73 - self.send(Task::new(encoded)).await?; [INFO] [stdout] 73 + self.send(Task::new(encoded))?; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:70:45 [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:70:45 [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:83:34 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:83:34 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:83:17 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:83:17 [INFO] [stdout] | [INFO] [stdout] 83 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] | |______________^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] | |______________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] 85 | | .collect::, _>>()?; [INFO] [stdout] | |___________________________________________^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:79:21 [INFO] [stdout] | [INFO] [stdout] 79 | let tasks = tasks [INFO] [stdout] | _____________________^ [INFO] [stdout] 80 | | .into_iter() [INFO] [stdout] 81 | | .map(Task::new) [INFO] [stdout] 82 | | .map(|task| { [INFO] [stdout] 83 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 84 | | }) [INFO] [stdout] 85 | | .collect::, _>>()?; [INFO] [stdout] | |___________________________________________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:86:14 [INFO] [stdout] | [INFO] [stdout] 86 | self.send_all(&mut stream::iter(tasks.into_iter().map(Ok))) [INFO] [stdout] | ^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `send_all` [INFO] [stdout] --> /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/futures-util-0.3.32/src/sink/mod.rs:65:26 [INFO] [stdout] | [INFO] [stdout] 65 | pub trait SinkExt: Sink { [INFO] [stdout] | ^^^^^^^^^^ required by this bound in `SinkExt::send_all` [INFO] [stdout] ... [INFO] [stdout] 252 | fn send_all<'a, St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> [INFO] [stdout] | -------- required by a bound in this associated function [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:87:14 [INFO] [stdout] | [INFO] [stdout] 87 | .await?; [INFO] [stdout] | ^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: required for `SendAll<'_, S, Iter>, ...>>>` to implement `futures_util::Future` [INFO] [stdout] = note: required for `SendAll<'_, S, Iter>, ...>>>` to implement `std::future::IntoFuture` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] help: remove the `.await` [INFO] [stdout] | [INFO] [stdout] 87 - .await?; [INFO] [stdout] 87 + ?; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:77:56 [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:77:56 [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0271]: type mismatch resolving ` as Stream>::Item == Result<..., ...>` [INFO] [stdout] --> src/backend/sink.rs:87:14 [INFO] [stdout] | [INFO] [stdout] 87 | .await?; [INFO] [stdout] | ^^^^^ expected `BackendExt::Compact`, found `Codec::Compact` [INFO] [stdout] | [INFO] [stdout] = note: expected enum `Result::Compact, _, _>, _>` [INFO] [stdout] found enum `Result>::Compact, _, _>, _>` [INFO] [stdout] = note: required for `SendAll<'_, S, Iter>, ...>>>` to implement `futures_util::Future` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-5617413851117484372.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:95:14 [INFO] [stdout] | [INFO] [stdout] 95 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: required for `&mut S` to implement `Sink>::Compact, ::Context, ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:95:9 [INFO] [stdout] | [INFO] [stdout] 95 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:95:9 [INFO] [stdout] | [INFO] [stdout] 95 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: the method `send_all` exists for struct `SinkMapErr<&mut S, {closure@src/backend/sink.rs:95:27: 95:30}>`, but its trait bounds were not satisfied [INFO] [stdout] --> src/backend/sink.rs:96:14 [INFO] [stdout] | [INFO] [stdout] 95 | / self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] 96 | | .send_all(&mut tasks.map(Task::new).map(|task| { [INFO] [stdout] | | -^^^^^^^^ method cannot be called due to unsatisfied trait bounds [INFO] [stdout] | |_____________| [INFO] [stdout] | [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/pin-project-lite-0.2.17/src/lib.rs:745:9 [INFO] [stdout] | [INFO] [stdout] 745 | / $vis struct $ident $($def_generics)* [INFO] [stdout] 746 | | $(where [INFO] [stdout] 747 | | $($where_clause)*)? [INFO] [stdout] ... | [INFO] [stdout] 751 | | ),+ [INFO] [stdout] 752 | | } [INFO] [stdout] | |_________- doesn't satisfy `_: Sink<_>` or `_: SinkExt<_>` [INFO] [stdout] | [INFO] [stdout] = note: the following trait bounds were not satisfied: [INFO] [stdout] `SinkMapErr<&mut S, {closure@src/backend/sink.rs:95:27: 95:30}>: futures_util::Sink<_>` [INFO] [stdout] which is required by `SinkMapErr<&mut S, {closure@src/backend/sink.rs:95:27: 95:30}>: futures_util::SinkExt<_>` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:97:34 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:97:34 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:97:17 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:97:17 [INFO] [stdout] | [INFO] [stdout] 97 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:96:28 [INFO] [stdout] | [INFO] [stdout] 96 | .send_all(&mut tasks.map(Task::new).map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 97 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 98 | | })) [INFO] [stdout] | |______________^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:96:28 [INFO] [stdout] | [INFO] [stdout] 96 | .send_all(&mut tasks.map(Task::new).map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 97 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 98 | | })) [INFO] [stdout] | |______________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:94:10 [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:94:10 [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:107:14 [INFO] [stdout] | [INFO] [stdout] 107 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: required for `&mut S` to implement `Sink>::Compact, ::Context, ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:107:9 [INFO] [stdout] | [INFO] [stdout] 107 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:107:9 [INFO] [stdout] | [INFO] [stdout] 107 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: the method `send` exists for struct `SinkMapErr<&mut S, {closure@src/backend/sink.rs:107:27: 107:30}>`, but its trait bounds were not satisfied [INFO] [stdout] --> src/backend/sink.rs:108:14 [INFO] [stdout] | [INFO] [stdout] 107 | / self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] 108 | | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | | -^^^^ method cannot be called due to unsatisfied trait bounds [INFO] [stdout] | |_____________| [INFO] [stdout] | [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/pin-project-lite-0.2.17/src/lib.rs:745:9 [INFO] [stdout] | [INFO] [stdout] 745 | / $vis struct $ident $($def_generics)* [INFO] [stdout] 746 | | $(where [INFO] [stdout] 747 | | $($where_clause)*)? [INFO] [stdout] ... | [INFO] [stdout] 751 | | ),+ [INFO] [stdout] 752 | | } [INFO] [stdout] | |_________- doesn't satisfy `_: Sink<_>` or `_: SinkExt<_>` [INFO] [stdout] | [INFO] [stdout] = note: the following trait bounds were not satisfied: [INFO] [stdout] `SinkMapErr<&mut S, {closure@src/backend/sink.rs:107:27: 107:30}>: futures_util::Sink<_>` [INFO] [stdout] which is required by `SinkMapErr<&mut S, {closure@src/backend/sink.rs:107:27: 107:30}>: futures_util::SinkExt<_>` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:108:36 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:108:36 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:108:19 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:108:19 [INFO] [stdout] | [INFO] [stdout] 108 | .send(task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into())))?) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:105:10 [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:105:10 [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:117:14 [INFO] [stdout] | [INFO] [stdout] 117 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: required for `&mut S` to implement `Sink>::Compact, ::Context, ...>>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:117:9 [INFO] [stdout] | [INFO] [stdout] 117 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:117:9 [INFO] [stdout] | [INFO] [stdout] 117 | self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: the method `send_all` exists for struct `SinkMapErr<&mut S, {closure@src/backend/sink.rs:117:27: 117:30}>`, but its trait bounds were not satisfied [INFO] [stdout] --> src/backend/sink.rs:118:14 [INFO] [stdout] | [INFO] [stdout] 117 | / self.sink_map_err(|e| TaskSinkError::PushError(e)) [INFO] [stdout] 118 | | .send_all(&mut tasks.map(|task| { [INFO] [stdout] | | -^^^^^^^^ method cannot be called due to unsatisfied trait bounds [INFO] [stdout] | |_____________| [INFO] [stdout] | [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/pin-project-lite-0.2.17/src/lib.rs:745:9 [INFO] [stdout] | [INFO] [stdout] 745 | / $vis struct $ident $($def_generics)* [INFO] [stdout] 746 | | $(where [INFO] [stdout] 747 | | $($where_clause)*)? [INFO] [stdout] ... | [INFO] [stdout] 751 | | ),+ [INFO] [stdout] 752 | | } [INFO] [stdout] | |_________- doesn't satisfy `_: Sink<_>` or `_: SinkExt<_>` [INFO] [stdout] | [INFO] [stdout] = note: the following trait bounds were not satisfied: [INFO] [stdout] `SinkMapErr<&mut S, {closure@src/backend/sink.rs:117:27: 117:30}>: futures_util::Sink<_>` [INFO] [stdout] which is required by `SinkMapErr<&mut S, {closure@src/backend/sink.rs:117:27: 117:30}>: futures_util::SinkExt<_>` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:119:34 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:119:34 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:119:17 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:119:17 [INFO] [stdout] | [INFO] [stdout] 119 | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:118:28 [INFO] [stdout] | [INFO] [stdout] 118 | .send_all(&mut tasks.map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 119 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 120 | | })) [INFO] [stdout] | |______________^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:118:28 [INFO] [stdout] | [INFO] [stdout] 118 | .send_all(&mut tasks.map(|task| { [INFO] [stdout] | ____________________________^ [INFO] [stdout] 119 | | task.try_map(|t| C::encode(&t).map_err(|e| TaskSinkError::CodecError(e.into()))) [INFO] [stdout] 120 | | })) [INFO] [stdout] | |______________^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:115:10 [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:58:8 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ required by this bound in `>` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:115:10 [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required by a bound in `>` [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ required by this bound in `>` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:29:10 [INFO] [stdout] | [INFO] [stdout] 29 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:29:10 [INFO] [stdout] | [INFO] [stdout] 29 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:35:10 [INFO] [stdout] | [INFO] [stdout] 35 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:35:10 [INFO] [stdout] | [INFO] [stdout] 35 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:41:10 [INFO] [stdout] | [INFO] [stdout] 41 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:41:10 [INFO] [stdout] | [INFO] [stdout] 41 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:47:10 [INFO] [stdout] | [INFO] [stdout] 47 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:47:10 [INFO] [stdout] | [INFO] [stdout] 47 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:53:10 [INFO] [stdout] | [INFO] [stdout] 53 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:53:10 [INFO] [stdout] | [INFO] [stdout] 53 | ) -> impl Future>> + Send; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: Sink::Compact, ..., ...>>` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:58:60 [INFO] [stdout] | [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | ^^^^^^^^^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] = note: the full name for the type has been written to '/opt/rustwide/target/debug/deps/apalis_core-1b73a9ddccfd1593.long-type-3064105986733511520.txt' [INFO] [stdout] = note: consider using `--verbose` to print the full type name to the console [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `S: backend::sink::TaskSink` is not satisfied [INFO] [stdout] --> src/backend/sink.rs:56:40 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^ unsatisfied trait bound [INFO] [stdout] | [INFO] [stdout] = help: the trait `futures_util::Sink::Compact, ::Context, ::IdType>>` is not implemented for `S` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] 57 | where [INFO] [stdout] 58 | S: Sink, Error = E> [INFO] [stdout] | -------------------------------------------------------------- unsatisfied trait bound introduced here [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:56:40 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] note: required for `S` to implement `backend::sink::TaskSink` [INFO] [stdout] --> src/backend/sink.rs:56:21 [INFO] [stdout] | [INFO] [stdout] 56 | impl TaskSink for S [INFO] [stdout] | ^^^^^^^^^^^^^^ ^ [INFO] [stdout] ... [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ---- unsatisfied trait bound introduced here [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 68 | C::Error: std::error::Error + Send + Sync + 'static, ::Compact: std::marker::Send [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 70 | async fn push(&mut self, task: Args) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 77 | async fn push_bulk(&mut self, tasks: Vec) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 94 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 105 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: `::Compact` cannot be sent between threads safely [INFO] [stdout] --> src/backend/sink.rs:63:17 [INFO] [stdout] | [INFO] [stdout] 63 | C::Compact: Send, [INFO] [stdout] | ^^^^ `::Compact` cannot be sent between threads safely [INFO] [stdout] | [INFO] [stdout] = help: the trait `std::marker::Send` is not implemented for `::Compact` [INFO] [stdout] help: consider further restricting the associated type [INFO] [stdout] | [INFO] [stdout] 115 | ) -> Result<(), TaskSinkError> where ::Compact: std::marker::Send { [INFO] [stdout] | +++++++++++++++++++++++++++++++++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0271, E0277, E0308, E0599. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0271`. [INFO] [stdout] [INFO] [stderr] error: could not compile `apalis-core` (lib test) due to 73 previous errors [INFO] running `Command { std: "docker" "inspect" "3be737738d3ec94d37a25f119189c72ec6ecaed2c56d97e4b2d0ea16f970a120", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "3be737738d3ec94d37a25f119189c72ec6ecaed2c56d97e4b2d0ea16f970a120", kill_on_drop: false }` [INFO] [stdout] 3be737738d3ec94d37a25f119189c72ec6ecaed2c56d97e4b2d0ea16f970a120