[INFO] cloning repository https://github.com/louloulin/kactor [INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/louloulin/kactor" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Flouloulin%2Fkactor", kill_on_drop: false }` [INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Flouloulin%2Fkactor'... [INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }` [INFO] [stdout] 3e95e468e9dbc07d53afafc408f93ff045aaa6d7 [INFO] testing louloulin/kactor against master#c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 for pr-146098-7 [INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Flouloulin%2Fkactor" "/workspace/builds/worker-7-tc1/source", kill_on_drop: false }` [INFO] [stderr] Cloning into '/workspace/builds/worker-7-tc1/source'... [INFO] [stderr] done. [INFO] started tweaking git repo https://github.com/louloulin/kactor [INFO] finished tweaking git repo https://github.com/louloulin/kactor [INFO] tweaked toml for git repo https://github.com/louloulin/kactor written to /workspace/builds/worker-7-tc1/source/Cargo.toml [INFO] validating manifest of git repo https://github.com/louloulin/kactor on toolchain c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate git repo https://github.com/louloulin/kactor 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" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded metrics-macros v0.7.1 [INFO] [stderr] Downloaded tokio-test v0.4.4 [INFO] [stderr] Downloaded metrics v0.21.1 [INFO] [stderr] Downloaded syn v2.0.91 [INFO] [stderr] Downloaded tokio v1.42.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] a6a86d321065fbfa0f1d7fad0497b4495508e36d2a11514671ad9ef8932a10fe [INFO] running `Command { std: "docker" "start" "-a" "a6a86d321065fbfa0f1d7fad0497b4495508e36d2a11514671ad9ef8932a10fe", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "a6a86d321065fbfa0f1d7fad0497b4495508e36d2a11514671ad9ef8932a10fe", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a6a86d321065fbfa0f1d7fad0497b4495508e36d2a11514671ad9ef8932a10fe", kill_on_drop: false }` [INFO] [stdout] a6a86d321065fbfa0f1d7fad0497b4495508e36d2a11514671ad9ef8932a10fe [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] c179c2a040cefce6498b60d2cb8fd41e562dc50fa174489d028bf0773404f18c [INFO] running `Command { std: "docker" "start" "-a" "c179c2a040cefce6498b60d2cb8fd41e562dc50fa174489d028bf0773404f18c", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.92 [INFO] [stderr] Compiling unicode-ident v1.0.14 [INFO] [stderr] Compiling byteorder v1.5.0 [INFO] [stderr] Compiling pin-project-lite v0.2.15 [INFO] [stderr] Compiling parking_lot_core v0.9.10 [INFO] [stderr] Compiling once_cell v1.20.2 [INFO] [stderr] Compiling serde v1.0.216 [INFO] [stderr] Compiling futures-core v0.3.31 [INFO] [stderr] Compiling smallvec v1.13.2 [INFO] [stderr] Compiling futures-sink v0.3.31 [INFO] [stderr] Compiling lock_api v0.4.12 [INFO] [stderr] Compiling indexmap v1.9.3 [INFO] [stderr] Compiling ahash v0.8.11 [INFO] [stderr] Compiling priority-queue v1.4.0 [INFO] [stderr] Compiling hashbrown v0.12.3 [INFO] [stderr] Compiling anyhow v1.0.95 [INFO] [stderr] Compiling indexmap v2.7.0 [INFO] [stderr] Compiling signal-hook-registry v1.4.2 [INFO] [stderr] Compiling ryu v1.0.18 [INFO] [stderr] Compiling tracing-core v0.1.33 [INFO] [stderr] Compiling unsafe-libyaml v0.2.11 [INFO] [stderr] Compiling bytes v1.9.0 [INFO] [stderr] Compiling uuid v1.11.0 [INFO] [stderr] Compiling log v0.4.22 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling parking_lot v0.12.3 [INFO] [stderr] Compiling dashmap v5.5.3 [INFO] [stderr] Compiling quote v1.0.37 [INFO] [stderr] Compiling syn v2.0.91 [INFO] [stderr] Compiling zerocopy-derive v0.7.35 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling serde_derive v1.0.216 [INFO] [stderr] Compiling metrics-macros v0.7.1 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Compiling tracing-attributes v0.1.28 [INFO] [stderr] Compiling tokio-macros v2.4.0 [INFO] [stderr] Compiling async-trait v0.1.83 [INFO] [stderr] Compiling tokio v1.42.0 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling zerocopy v0.7.35 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling ppv-lite86 v0.2.20 [INFO] [stderr] Compiling metrics v0.21.1 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling rand_chacha v0.3.1 [INFO] [stderr] Compiling rand v0.8.5 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling bincode v1.3.3 [INFO] [stderr] Compiling serde_yaml v0.9.34+deprecated [INFO] [stderr] Compiling protoactor v0.1.0 (/opt/rustwide/workdir) [INFO] [stdout] error[E0432]: unresolved imports `crate::Message`, `crate::Pid`, `crate::Transport` [INFO] [stdout] --> src/remote/endpoint.rs:3:13 [INFO] [stdout] | [INFO] [stdout] 3 | use crate::{Message, Pid, SendError, ActorSystem, Transport}; [INFO] [stdout] | ^^^^^^^ ^^^ ^^^^^^^^^ no `Transport` in the root [INFO] [stdout] | | | [INFO] [stdout] | | no `Pid` in the root [INFO] [stdout] | no `Message` in the root [INFO] [stdout] | help: a similar name exists in the module: `message` [INFO] [stdout] | [INFO] [stdout] = help: consider importing this struct instead: [INFO] [stdout] crate::message::Message [INFO] [stdout] = help: consider importing this trait through its public re-export instead: [INFO] [stdout] crate::remote::Transport [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `connection_pool` [INFO] [stdout] --> src/remote/endpoint.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use connection_pool::ConnectionPool; [INFO] [stdout] | ^^^^^^^^^^^^^^^ use of unresolved module or unlinked crate `connection_pool` [INFO] [stdout] | [INFO] [stdout] help: to make use of source file src/remote/connection_pool.rs, use `mod connection_pool` in this file to declare the module [INFO] [stdout] --> src/lib.rs:4:1 [INFO] [stdout] | [INFO] [stdout] 4 + mod connection_pool; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `heartbeat` [INFO] [stdout] --> src/remote/endpoint.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use heartbeat::HeartbeatManager; [INFO] [stdout] | ^^^^^^^^^ use of unresolved module or unlinked crate `heartbeat` [INFO] [stdout] | [INFO] [stdout] help: to make use of source file src/remote/heartbeat.rs, use `mod heartbeat` in this file to declare the module [INFO] [stdout] --> src/lib.rs:4:1 [INFO] [stdout] | [INFO] [stdout] 4 + mod heartbeat; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `reconnection` [INFO] [stdout] --> src/remote/endpoint.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | use reconnection::ReconnectionStrategy; [INFO] [stdout] | ^^^^^^^^^^^^ use of unresolved module or unlinked crate `reconnection` [INFO] [stdout] | [INFO] [stdout] help: to make use of source file src/remote/reconnection.rs, use `mod reconnection` in this file to declare the module [INFO] [stdout] --> src/lib.rs:4:1 [INFO] [stdout] | [INFO] [stdout] 4 + mod reconnection; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved imports `crate::Message`, `crate::MessageHeader`, `crate::Pid` [INFO] [stdout] --> src/remote/serialization.rs:3:13 [INFO] [stdout] | [INFO] [stdout] 3 | use crate::{Message, MessageHeader, Pid}; [INFO] [stdout] | ^^^^^^^ ^^^^^^^^^^^^^ ^^^ no `Pid` in the root [INFO] [stdout] | | | [INFO] [stdout] | | no `MessageHeader` in the root [INFO] [stdout] | no `Message` in the root [INFO] [stdout] | help: a similar name exists in the module: `message` [INFO] [stdout] | [INFO] [stdout] = help: consider importing this struct instead: [INFO] [stdout] crate::message::Message [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved imports `crate::Message`, `crate::Pid`, `crate::RemoteConfig` [INFO] [stdout] --> src/remote/transport.rs:3:13 [INFO] [stdout] | [INFO] [stdout] 3 | use crate::{Message, Pid, SendError, RemoteConfig}; [INFO] [stdout] | ^^^^^^^ ^^^ ^^^^^^^^^^^^ no `RemoteConfig` in the root [INFO] [stdout] | | | [INFO] [stdout] | | no `Pid` in the root [INFO] [stdout] | no `Message` in the root [INFO] [stdout] | help: a similar name exists in the module: `message` [INFO] [stdout] | [INFO] [stdout] = help: consider importing this struct instead: [INFO] [stdout] crate::message::Message [INFO] [stdout] = help: consider importing this struct instead: [INFO] [stdout] crate::remote::RemoteConfig [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved imports `crate::Message`, `crate::Pid` [INFO] [stdout] --> src/remote/mod.rs:12:26 [INFO] [stdout] | [INFO] [stdout] 12 | use crate::{ActorSystem, Message, Pid, SendError}; [INFO] [stdout] | ^^^^^^^ ^^^ no `Pid` in the root [INFO] [stdout] | | [INFO] [stdout] | no `Message` in the root [INFO] [stdout] | help: a similar name exists in the module: `message` [INFO] [stdout] | [INFO] [stdout] = help: consider importing this struct instead: [INFO] [stdout] crate::message::Message [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `crate::remote::message_handler` [INFO] [stdout] --> src/remote/mod.rs:13:20 [INFO] [stdout] | [INFO] [stdout] 13 | use crate::remote::message_handler::RemoteMessageHandler; [INFO] [stdout] | ^^^^^^^^^^^^^^^ could not find `message_handler` in `remote` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `crate::remote::errors` [INFO] [stdout] --> src/remote/mod.rs:14:20 [INFO] [stdout] | [INFO] [stdout] 14 | use crate::remote::errors::RemoteError; [INFO] [stdout] | ^^^^^^ could not find `errors` in `remote` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `crate::remote::system_message` [INFO] [stdout] --> src/remote/mod.rs:15:20 [INFO] [stdout] | [INFO] [stdout] 15 | use crate::remote::system_message::SystemMessage; [INFO] [stdout] | ^^^^^^^^^^^^^^ could not find `system_message` in `remote` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `crate::workflow::SourceConfig` [INFO] [stdout] --> src/workflow/actors/source.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use crate::workflow::SourceConfig; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `SourceConfig` in `workflow` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `crate::workflow::SinkConfig` [INFO] [stdout] --> src/workflow/actors/sink.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use crate::workflow::SinkConfig; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `SinkConfig` in `workflow` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved imports `crate::workflow::SourceConfig`, `crate::workflow::SinkConfig`, `crate::workflow::RetryPolicy` [INFO] [stdout] --> src/workflow/actors/mod.rs:10:27 [INFO] [stdout] | [INFO] [stdout] 10 | pub use crate::workflow::{SourceConfig, SinkConfig, RetryPolicy}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^ no `RetryPolicy` in `workflow` [INFO] [stdout] | | | [INFO] [stdout] | | no `SinkConfig` in `workflow` [INFO] [stdout] | no `SourceConfig` in `workflow` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: cannot find attribute `async_trait` in this scope [INFO] [stdout] --> src/workflow/quality.rs:7:3 [INFO] [stdout] | [INFO] [stdout] 7 | #[async_trait] [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `async_trait` is in scope, but it is a crate, not an attribute [INFO] [stdout] help: consider importing one of these attribute macros [INFO] [stdout] | [INFO] [stdout] 1 + use crate::async_trait; [INFO] [stdout] | [INFO] [stdout] 1 + use async_trait::async_trait; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Metrics` in this scope [INFO] [stdout] --> src/middleware/common.rs:31:18 [INFO] [stdout] | [INFO] [stdout] 31 | metrics: Arc, [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 30 | pub struct MetricsMiddleware { [INFO] [stdout] | +++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `ExponentialBackoff` in this scope [INFO] [stdout] --> src/middleware/common.rs:58:14 [INFO] [stdout] | [INFO] [stdout] 58 | backoff: ExponentialBackoff, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `RwLock` in this scope [INFO] [stdout] --> src/middleware/common.rs:87:16 [INFO] [stdout] | [INFO] [stdout] 87 | state: Arc>, [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these items [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::RwLock; [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::nonpoison::RwLock; [INFO] [stdout] | [INFO] [stdout] 1 + use parking_lot::RwLock; [INFO] [stdout] | [INFO] [stdout] 1 + use tokio::sync::RwLock; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `CircuitBreakerState` in this scope [INFO] [stdout] --> src/middleware/common.rs:87:23 [INFO] [stdout] | [INFO] [stdout] 87 | state: Arc>, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 86 | pub struct CircuitBreakerMiddleware { [INFO] [stdout] | +++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `CircuitBreakerConfig` in this scope [INFO] [stdout] --> src/middleware/common.rs:88:13 [INFO] [stdout] | [INFO] [stdout] 88 | config: CircuitBreakerConfig, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `HeartbeatMessage` in this scope [INFO] [stdout] --> src/remote/endpoint.rs:58:51 [INFO] [stdout] | [INFO] [stdout] 58 | pub async fn send_heartbeat(&self, heartbeat: HeartbeatMessage) -> Result<(), SendError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `DashMap` in this scope [INFO] [stdout] --> src/remote/endpoint.rs:65:16 [INFO] [stdout] | [INFO] [stdout] 65 | endpoints: DashMap>, [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 1 + use crate::remote::DashMap; [INFO] [stdout] | [INFO] [stdout] 1 + use dashmap::DashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `DashMap` [INFO] [stdout] --> src/remote/endpoint.rs:71:24 [INFO] [stdout] | [INFO] [stdout] 71 | endpoints: DashMap::new(), [INFO] [stdout] | ^^^^^^^ use of undeclared type `DashMap` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 1 + use crate::remote::DashMap; [INFO] [stdout] | [INFO] [stdout] 1 + use dashmap::DashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `SerializationError` in this scope [INFO] [stdout] --> src/remote/serialization.rs:7:69 [INFO] [stdout] | [INFO] [stdout] 7 | async fn serialize(&self, message: &Message) -> Result, SerializationError>; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 6 | pub trait Serializer: Send + Sync { [INFO] [stdout] | ++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `SerializationError` in this scope [INFO] [stdout] --> src/remote/serialization.rs:8:66 [INFO] [stdout] | [INFO] [stdout] 8 | async fn deserialize(&self, bytes: &[u8]) -> Result; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 6 | pub trait Serializer: Send + Sync { [INFO] [stdout] | ++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `DashMap` in this scope [INFO] [stdout] --> src/remote/serialization.rs:21:18 [INFO] [stdout] | [INFO] [stdout] 21 | serializers: DashMap>, [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 1 + use crate::remote::DashMap; [INFO] [stdout] | [INFO] [stdout] 1 + use dashmap::DashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `DashMap` [INFO] [stdout] --> src/remote/serialization.rs:27:26 [INFO] [stdout] | [INFO] [stdout] 27 | serializers: DashMap::new(), [INFO] [stdout] | ^^^^^^^ use of undeclared type `DashMap` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these structs [INFO] [stdout] | [INFO] [stdout] 1 + use crate::remote::DashMap; [INFO] [stdout] | [INFO] [stdout] 1 + use dashmap::DashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `SerializationError` in this scope [INFO] [stdout] --> src/remote/serialization.rs:35:87 [INFO] [stdout] | [INFO] [stdout] 35 | pub async fn serialize(&self, message: &Message, target: &Pid) -> Result, SerializationError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 24 | impl MessageSerializer { [INFO] [stdout] | ++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `SerializationError` in this scope [INFO] [stdout] --> src/remote/serialization.rs:52:82 [INFO] [stdout] | [INFO] [stdout] 52 | pub async fn serialize_batch(&self, messages: &[Message]) -> Result, SerializationError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 24 | impl MessageSerializer { [INFO] [stdout] | ++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `SerializationError` in this scope [INFO] [stdout] --> src/remote/serialization.rs:70:80 [INFO] [stdout] | [INFO] [stdout] 70 | pub async fn deserialize_batch(&self, data: &[u8]) -> Result, SerializationError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 24 | impl MessageSerializer { [INFO] [stdout] | ++++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `RemoteError` in this scope [INFO] [stdout] --> src/remote/transport.rs:7:64 [INFO] [stdout] | [INFO] [stdout] 7 | async fn start(&self, config: &RemoteConfig) -> Result<(), RemoteError>; [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 6 | pub trait Transport: Send + Sync { [INFO] [stdout] | +++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `RemoteError` in this scope [INFO] [stdout] --> src/remote/transport.rs:14:52 [INFO] [stdout] | [INFO] [stdout] 14 | async fn receive(&mut self) -> Result; [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 12 | pub trait Connection: Send + Sync { [INFO] [stdout] | +++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `RemoteError` in this scope [INFO] [stdout] --> src/remote/transport.rs:29:64 [INFO] [stdout] | [INFO] [stdout] 29 | async fn start(&self, config: &RemoteConfig) -> Result<(), RemoteError> { [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 28 | impl Transport for TcpTransport { [INFO] [stdout] | +++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `AtomicUsize` in this scope [INFO] [stdout] --> src/workflow/backpressure.rs:3:26 [INFO] [stdout] | [INFO] [stdout] 3 | current_buffer_size: AtomicUsize, [INFO] [stdout] | ^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::AtomicUsize; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `mpsc` [INFO] [stdout] --> src/workflow/backpressure.rs:6:22 [INFO] [stdout] | [INFO] [stdout] 6 | throttle_sender: mpsc::Sender, [INFO] [stdout] | ^^^^ use of unresolved module or unlinked crate `mpsc` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `mpsc`, use `cargo add mpsc` to add it to your `Cargo.toml` [INFO] [stdout] = note: module `crate::mailbox::priority::mpsc` exists but is inaccessible [INFO] [stdout] help: consider importing one of these modules [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::mpsc; [INFO] [stdout] | [INFO] [stdout] 1 + use tokio::sync::mpsc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of unresolved module or unlinked crate `mpsc` [INFO] [stdout] --> src/workflow/backpressure.rs:18:24 [INFO] [stdout] | [INFO] [stdout] 18 | let (tx, rx) = mpsc::channel(100); [INFO] [stdout] | ^^^^ use of unresolved module or unlinked crate `mpsc` [INFO] [stdout] | [INFO] [stdout] = help: if you wanted to use a crate named `mpsc`, use `cargo add mpsc` to add it to your `Cargo.toml` [INFO] [stdout] = note: module `crate::mailbox::priority::mpsc` exists but is inaccessible [INFO] [stdout] help: consider importing one of these modules [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::mpsc; [INFO] [stdout] | [INFO] [stdout] 1 + use tokio::sync::mpsc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `AtomicUsize` [INFO] [stdout] --> src/workflow/backpressure.rs:21:34 [INFO] [stdout] | [INFO] [stdout] 21 | current_buffer_size: AtomicUsize::new(0), [INFO] [stdout] | ^^^^^^^^^^^ use of undeclared type `AtomicUsize` [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::AtomicUsize; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Ordering` [INFO] [stdout] --> src/workflow/backpressure.rs:29:53 [INFO] [stdout] | [INFO] [stdout] 29 | let current = self.current_buffer_size.load(Ordering::Relaxed); [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Ordering` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these enums [INFO] [stdout] | [INFO] [stdout] 1 + use std::cmp::Ordering; [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::Ordering; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Ordering` [INFO] [stdout] --> src/workflow/backpressure.rs:36:54 [INFO] [stdout] | [INFO] [stdout] 36 | self.current_buffer_size.store(new_size, Ordering::Relaxed); [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Ordering` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these enums [INFO] [stdout] | [INFO] [stdout] 1 + use std::cmp::Ordering; [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::Ordering; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Ordering` [INFO] [stdout] --> src/workflow/backpressure.rs:42:53 [INFO] [stdout] | [INFO] [stdout] 42 | let current = self.current_buffer_size.load(Ordering::Relaxed); [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Ordering` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these enums [INFO] [stdout] | [INFO] [stdout] 1 + use std::cmp::Ordering; [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::Ordering; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Ordering` [INFO] [stdout] --> src/workflow/backpressure.rs:44:50 [INFO] [stdout] | [INFO] [stdout] 44 | self.current_buffer_size.store(new_size, Ordering::Relaxed); [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Ordering` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these enums [INFO] [stdout] | [INFO] [stdout] 1 + use std::cmp::Ordering; [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::Ordering; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Ordering` [INFO] [stdout] --> src/workflow/backpressure.rs:58:39 [INFO] [stdout] | [INFO] [stdout] 58 | self.current_buffer_size.load(Ordering::Relaxed) [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Ordering` [INFO] [stdout] | [INFO] [stdout] help: consider importing one of these enums [INFO] [stdout] | [INFO] [stdout] 1 + use std::cmp::Ordering; [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::atomic::Ordering; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/errors.rs:26:26 [INFO] [stdout] | [INFO] [stdout] 26 | impl From for WorkflowError { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `WorkflowError` [INFO] [stdout] --> src/workflow/errors.rs:28:9 [INFO] [stdout] | [INFO] [stdout] 28 | WorkflowError::StepFailed(err.to_string()) [INFO] [stdout] | ^^^^^^^^^^^^^ use of undeclared type `WorkflowError` [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Arc` in this scope [INFO] [stdout] --> src/workflow/loader.rs:6:15 [INFO] [stdout] | [INFO] [stdout] 6 | registry: Arc>, [INFO] [stdout] | ^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] = note: struct `crate::mailbox::unbounded::Arc` exists but is inaccessible [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::Arc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `DashMap` in this scope [INFO] [stdout] --> src/workflow/loader.rs:6:19 [INFO] [stdout] | [INFO] [stdout] 6 | registry: Arc>, [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use dashmap::DashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Arc` in this scope [INFO] [stdout] --> src/workflow/loader.rs:7:20 [INFO] [stdout] | [INFO] [stdout] 7 | actor_factory: Arc, [INFO] [stdout] | ^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] = note: struct `crate::mailbox::unbounded::Arc` exists but is inaccessible [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::Arc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Arc` in this scope [INFO] [stdout] --> src/workflow/loader.rs:11:31 [INFO] [stdout] | [INFO] [stdout] 11 | pub fn new(actor_factory: Arc) -> Self { [INFO] [stdout] | ^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] = note: struct `crate::mailbox::unbounded::Arc` exists but is inaccessible [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::Arc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Arc` [INFO] [stdout] --> src/workflow/loader.rs:13:23 [INFO] [stdout] | [INFO] [stdout] 13 | registry: Arc::new(DashMap::new()), [INFO] [stdout] | ^^^ use of undeclared type `Arc` [INFO] [stdout] | [INFO] [stdout] = note: struct `crate::mailbox::unbounded::Arc` exists but is inaccessible [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::Arc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `DashMap` [INFO] [stdout] --> src/workflow/loader.rs:13:32 [INFO] [stdout] | [INFO] [stdout] 13 | registry: Arc::new(DashMap::new()), [INFO] [stdout] | ^^^^^^^ use of undeclared type `DashMap` [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use dashmap::DashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/loader.rs:18:79 [INFO] [stdout] | [INFO] [stdout] 18 | pub async fn load_directory>(&self, path: P) -> Result<(), WorkflowError> { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/loader.rs:30:74 [INFO] [stdout] | [INFO] [stdout] 30 | pub async fn load_file>(&self, path: P) -> Result<(), WorkflowError> { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `DagActor` in this scope [INFO] [stdout] --> src/workflow/loader.rs:41:63 [INFO] [stdout] | [INFO] [stdout] 41 | pub async fn create_workflow(&self, name: &str) -> Result { [INFO] [stdout] | ^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 10 | impl WorkflowLoader { [INFO] [stdout] | ++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/loader.rs:41:73 [INFO] [stdout] | [INFO] [stdout] 41 | pub async fn create_workflow(&self, name: &str) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `WorkflowError` [INFO] [stdout] --> src/workflow/loader.rs:43:28 [INFO] [stdout] | [INFO] [stdout] 43 | .ok_or_else(|| WorkflowError::NotFound(name.to_string()))?; [INFO] [stdout] | ^^^^^^^^^^^^^ use of undeclared type `WorkflowError` [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `ParallelismManager` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:3:26 [INFO] [stdout] | [INFO] [stdout] 3 | parallelism_manager: ParallelismManager, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `MemoryManager` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:6:21 [INFO] [stdout] | [INFO] [stdout] 6 | memory_manager: MemoryManager, [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `BatchOptimizer` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:9:22 [INFO] [stdout] | [INFO] [stdout] 9 | batch_optimizer: BatchOptimizer, [INFO] [stdout] | ^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowScheduler` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:12:16 [INFO] [stdout] | [INFO] [stdout] 12 | scheduler: WorkflowScheduler, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::workflow::WorkflowScheduler; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowMetrics` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:16:48 [INFO] [stdout] | [INFO] [stdout] 16 | pub async fn optimize(&mut self, metrics: &WorkflowMetrics) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::workflow::WorkflowMetrics; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `OptimizationPlan` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:16:75 [INFO] [stdout] | [INFO] [stdout] 16 | pub async fn optimize(&mut self, metrics: &WorkflowMetrics) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 15 | impl WorkflowOptimizer { [INFO] [stdout] | ++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:16:93 [INFO] [stdout] | [INFO] [stdout] 16 | pub async fn optimize(&mut self, metrics: &WorkflowMetrics) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0422]: cannot find struct, variant or union type `OptimizationPlan` in this scope [INFO] [stdout] --> src/workflow/optimization.rs:22:12 [INFO] [stdout] | [INFO] [stdout] 22 | Ok(OptimizationPlan { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Arc` in this scope [INFO] [stdout] --> src/workflow/quality.rs:3:14 [INFO] [stdout] | [INFO] [stdout] 3 | metrics: Arc, [INFO] [stdout] | ^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] = note: struct `crate::mailbox::unbounded::Arc` exists but is inaccessible [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::Arc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `QualityMetrics` in this scope [INFO] [stdout] --> src/workflow/quality.rs:3:18 [INFO] [stdout] | [INFO] [stdout] 3 | metrics: Arc, [INFO] [stdout] | ^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 1 | pub struct DataQualityMonitor { [INFO] [stdout] | ++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `AlertManager` in this scope [INFO] [stdout] --> src/workflow/quality.rs:4:20 [INFO] [stdout] | [INFO] [stdout] 4 | alert_manager: AlertManager, [INFO] [stdout] | ^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Message` in this scope [INFO] [stdout] --> src/workflow/quality.rs:9:35 [INFO] [stdout] | [INFO] [stdout] 9 | async fn check(&self, data: &[Message]) -> DataQualityResult; [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use crate::message::Message; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `DataQualityResult` in this scope [INFO] [stdout] --> src/workflow/quality.rs:9:48 [INFO] [stdout] | [INFO] [stdout] 9 | async fn check(&self, data: &[Message]) -> DataQualityResult; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Severity` in this scope [INFO] [stdout] --> src/workflow/quality.rs:10:27 [INFO] [stdout] | [INFO] [stdout] 10 | fn severity(&self) -> Severity; [INFO] [stdout] | ^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Message` in this scope [INFO] [stdout] --> src/workflow/quality.rs:14:46 [INFO] [stdout] | [INFO] [stdout] 14 | pub async fn check_batch(&self, batch: &[Message]) -> Vec { [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use crate::message::Message; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `DataQualityResult` in this scope [INFO] [stdout] --> src/workflow/quality.rs:14:63 [INFO] [stdout] | [INFO] [stdout] 8 | pub trait DataQualityRule: Send + Sync { [INFO] [stdout] | -------------------------------------- similarly named trait `DataQualityRule` defined here [INFO] [stdout] ... [INFO] [stdout] 14 | pub async fn check_batch(&self, batch: &[Message]) -> Vec { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] help: a trait with a similar name exists [INFO] [stdout] | [INFO] [stdout] 14 - pub async fn check_batch(&self, batch: &[Message]) -> Vec { [INFO] [stdout] 14 + pub async fn check_batch(&self, batch: &[Message]) -> Vec { [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 13 | impl DataQualityMonitor { [INFO] [stdout] | +++++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `HashMap` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:2:18 [INFO] [stdout] | [INFO] [stdout] 2 | checkpoints: HashMap, [INFO] [stdout] | ^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::collections::HashMap; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Checkpoint` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:2:34 [INFO] [stdout] | [INFO] [stdout] 2 | checkpoints: HashMap, [INFO] [stdout] | ^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::workflow::Checkpoint; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Arc` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:3:18 [INFO] [stdout] | [INFO] [stdout] 3 | state_store: Arc, [INFO] [stdout] | ^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] = note: struct `crate::mailbox::unbounded::Arc` exists but is inaccessible [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use std::sync::Arc; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0405]: cannot find trait `StateStore` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:3:26 [INFO] [stdout] | [INFO] [stdout] 3 | state_store: Arc, [INFO] [stdout] | ^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `RecoveryPolicy` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:4:22 [INFO] [stdout] | [INFO] [stdout] 4 | recovery_policy: RecoveryPolicy, [INFO] [stdout] | ^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:8:66 [INFO] [stdout] | [INFO] [stdout] 8 | pub async fn handle_failure(&mut self, step_id: &str, error: WorkflowError) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `RecoveryAction` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:8:91 [INFO] [stdout] | [INFO] [stdout] 8 | pub async fn handle_failure(&mut self, step_id: &str, error: WorkflowError) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 7 | impl RecoveryManager { [INFO] [stdout] | ++++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/recovery.rs:8:107 [INFO] [stdout] | [INFO] [stdout] 8 | pub async fn handle_failure(&mut self, step_id: &str, error: WorkflowError) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `PriorityQueue` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:2:17 [INFO] [stdout] | [INFO] [stdout] 2 | task_queue: PriorityQueue, [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct [INFO] [stdout] | [INFO] [stdout] 1 + use priority_queue::PriorityQueue; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `TaskId` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:2:31 [INFO] [stdout] | [INFO] [stdout] 2 | task_queue: PriorityQueue, [INFO] [stdout] | ^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 1 | pub struct WorkflowScheduler { [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Priority` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:2:39 [INFO] [stdout] | [INFO] [stdout] 2 | task_queue: PriorityQueue, [INFO] [stdout] | ^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: there is an enum variant `crate::mailbox::MailboxKind::Priority`; try using the variant's enum [INFO] [stdout] | [INFO] [stdout] 2 - task_queue: PriorityQueue, [INFO] [stdout] 2 + task_queue: PriorityQueue, [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 1 | pub struct WorkflowScheduler { [INFO] [stdout] | ++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `ResourceManager` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:3:23 [INFO] [stdout] | [INFO] [stdout] 3 | resource_manager: ResourceManager, [INFO] [stdout] | ^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `CostModel` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:4:17 [INFO] [stdout] | [INFO] [stdout] 4 | cost_model: CostModel, [INFO] [stdout] | ^^^^^^^^^ not found in this scope [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `Task` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:8:49 [INFO] [stdout] | [INFO] [stdout] 8 | pub async fn schedule(&mut self, tasks: Vec) -> Result { [INFO] [stdout] | ^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 7 | impl WorkflowScheduler { [INFO] [stdout] | ++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `SchedulePlan` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:8:66 [INFO] [stdout] | [INFO] [stdout] 8 | pub async fn schedule(&mut self, tasks: Vec) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: you might be missing a type parameter [INFO] [stdout] | [INFO] [stdout] 7 | impl WorkflowScheduler { [INFO] [stdout] | ++++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowError` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:8:80 [INFO] [stdout] | [INFO] [stdout] 8 | pub async fn schedule(&mut self, tasks: Vec) -> Result { [INFO] [stdout] | ^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this enum through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::WorkflowError; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0412]: cannot find type `WorkflowMetrics` in this scope [INFO] [stdout] --> src/workflow/scheduler.rs:27:48 [INFO] [stdout] | [INFO] [stdout] 27 | pub async fn optimize(&mut self, metrics: &WorkflowMetrics) { [INFO] [stdout] | ^^^^^^^^^^^^^^^ not found in this scope [INFO] [stdout] | [INFO] [stdout] help: consider importing this struct through its public re-export [INFO] [stdout] | [INFO] [stdout] 1 + use crate::workflow::WorkflowMetrics; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0603]: struct import `Context` is private [INFO] [stdout] --> src/workflow/actors/source.rs:1:27 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::actor::{Actor, Context}; [INFO] [stdout] | ^^^^^^^ private struct import [INFO] [stdout] | [INFO] [stdout] note: the struct import `Context` is defined here... [INFO] [stdout] --> src/actor/mod.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use crate::context::Context; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] note: ...and refers to the struct import `Context` which is defined here... [INFO] [stdout] --> src/context/mod.rs:4:9 [INFO] [stdout] | [INFO] [stdout] 4 | pub use context::Context; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ you could import this re-export [INFO] [stdout] note: ...and refers to the struct `Context` which is defined here [INFO] [stdout] --> src/context/context.rs:11:1 [INFO] [stdout] | [INFO] [stdout] 11 | pub struct Context { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ you could import this directly [INFO] [stdout] help: import `Context` through the re-export [INFO] [stdout] | [INFO] [stdout] 1 | use crate::actor::{Actor, context::Context}; [INFO] [stdout] | +++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0603]: struct import `Context` is private [INFO] [stdout] --> src/workflow/actors/transform.rs:1:27 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::actor::{Actor, Context}; [INFO] [stdout] | ^^^^^^^ private struct import [INFO] [stdout] | [INFO] [stdout] note: the struct import `Context` is defined here... [INFO] [stdout] --> src/actor/mod.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use crate::context::Context; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] note: ...and refers to the struct import `Context` which is defined here... [INFO] [stdout] --> src/context/mod.rs:4:9 [INFO] [stdout] | [INFO] [stdout] 4 | pub use context::Context; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ you could import this re-export [INFO] [stdout] note: ...and refers to the struct `Context` which is defined here [INFO] [stdout] --> src/context/context.rs:11:1 [INFO] [stdout] | [INFO] [stdout] 11 | pub struct Context { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ you could import this directly [INFO] [stdout] help: import `Context` through the re-export [INFO] [stdout] | [INFO] [stdout] 1 | use crate::actor::{Actor, context::Context}; [INFO] [stdout] | +++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0603]: struct import `Context` is private [INFO] [stdout] --> src/workflow/actors/sink.rs:1:27 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::actor::{Actor, Context}; [INFO] [stdout] | ^^^^^^^ private struct import [INFO] [stdout] | [INFO] [stdout] note: the struct import `Context` is defined here... [INFO] [stdout] --> src/actor/mod.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use crate::context::Context; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] note: ...and refers to the struct import `Context` which is defined here... [INFO] [stdout] --> src/context/mod.rs:4:9 [INFO] [stdout] | [INFO] [stdout] 4 | pub use context::Context; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ you could import this re-export [INFO] [stdout] note: ...and refers to the struct `Context` which is defined here [INFO] [stdout] --> src/context/context.rs:11:1 [INFO] [stdout] | [INFO] [stdout] 11 | pub struct Context { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ you could import this directly [INFO] [stdout] help: import `Context` through the re-export [INFO] [stdout] | [INFO] [stdout] 1 | use crate::actor::{Actor, context::Context}; [INFO] [stdout] | +++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> src/middleware/message_middleware.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `MockActor` [INFO] [stdout] --> src/props.rs:2:37 [INFO] [stdout] | [INFO] [stdout] 2 | use crate::actor::{Actor, ActorRef, MockActor}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `SendError` [INFO] [stdout] --> src/supervision/strategy.rs:4:13 [INFO] [stdout] | [INFO] [stdout] 4 | use crate::{SendError}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::sync::RwLock` [INFO] [stdout] --> src/remote/mod.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use tokio::sync::RwLock; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `ActorSystem` [INFO] [stdout] --> src/remote/mod.rs:12:13 [INFO] [stdout] | [INFO] [stdout] 12 | use crate::{ActorSystem, Message, Pid, SendError}; [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::net::SocketAddr` [INFO] [stdout] --> src/remote/mod.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use std::net::SocketAddr; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `TcpStream` [INFO] [stdout] --> src/remote/mod.rs:17:31 [INFO] [stdout] | [INFO] [stdout] 17 | use tokio::net::{TcpListener, TcpStream}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> src/mailbox/metrics.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `metrics::*` [INFO] [stdout] --> src/mailbox/mod.rs:13:9 [INFO] [stdout] | [INFO] [stdout] 13 | pub use metrics::*; [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `oneshot` [INFO] [stdout] --> src/mailbox/mod.rs:16:25 [INFO] [stdout] | [INFO] [stdout] 16 | use tokio::sync::{mpsc, oneshot}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `ActorRef` [INFO] [stdout] --> src/mailbox/mod.rs:17:27 [INFO] [stdout] | [INFO] [stdout] 17 | use crate::actor::{Actor, ActorRef}; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> src/workflow/metrics.rs:2:5 [INFO] [stdout] | [INFO] [stdout] 2 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Serialize` and `de::DeserializeOwned` [INFO] [stdout] --> src/workflow/state.rs:3:13 [INFO] [stdout] | [INFO] [stdout] 3 | use serde::{Serialize, de::DeserializeOwned}; [INFO] [stdout] | ^^^^^^^^^ ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0107]: struct takes 0 generic arguments but 1 generic argument was supplied [INFO] [stdout] --> src/actor/builder.rs:8:12 [INFO] [stdout] | [INFO] [stdout] 8 | props: Props, [INFO] [stdout] | ^^^^^--- help: remove the unnecessary generics [INFO] [stdout] | | [INFO] [stdout] | expected 0 generic arguments [INFO] [stdout] | [INFO] [stdout] note: struct defined here, with 0 generic parameters [INFO] [stdout] --> src/props.rs:9:12 [INFO] [stdout] | [INFO] [stdout] 9 | pub struct Props { [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/basic_actors.rs:15:38 [INFO] [stdout] | [INFO] [stdout] 15 | async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut ForwardActor, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut ForwardActor, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 15 - async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] 15 + async fn receive(&mut self, ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/basic_actors.rs:29:39 [INFO] [stdout] | [INFO] [stdout] 29 | async fn receive(&mut self, _ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut BatchActor<_>, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut BatchActor<_>, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 29 - async fn receive(&mut self, _ctx: &mut Context, msg: Message) { [INFO] [stdout] 29 + async fn receive(&mut self, _ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `stopped` has an incompatible type for trait [INFO] [stdout] --> src/actor/basic_actors.rs:40:39 [INFO] [stdout] | [INFO] [stdout] 40 | async fn stopped(&mut self, _ctx: &mut Context) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:32:39 [INFO] [stdout] | [INFO] [stdout] 32 | async fn stopped(&mut self, _ctx: &Context) -> Result<(), SendError> { [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut BatchActor<_>, &'life1 context::context::Context) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut BatchActor<_>, &'life1 mut context::context::Context) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 40 - async fn stopped(&mut self, _ctx: &mut Context) { [INFO] [stdout] 40 + async fn stopped(&mut self, _ctx: &'life1 context::context::Context) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/basic_actors.rs:71:38 [INFO] [stdout] | [INFO] [stdout] 71 | async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut BroadcastActor, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut BroadcastActor, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 71 - async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] 71 + async fn receive(&mut self, ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/basic_actors.rs:86:38 [INFO] [stdout] | [INFO] [stdout] 86 | async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut FilterActor<_>, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut FilterActor<_>, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 86 - async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] 86 + async fn receive(&mut self, ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/basic_actors.rs:103:38 [INFO] [stdout] | [INFO] [stdout] 103 | async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut basic_actors::TransformActor<_, _>, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut basic_actors::TransformActor<_, _>, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 103 - async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] 103 + async fn receive(&mut self, ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/decorators.rs:16:38 [INFO] [stdout] | [INFO] [stdout] 16 | async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut ThrottleDecorator<_>, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut ThrottleDecorator<_>, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 16 - async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] 16 + async fn receive(&mut self, ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0053]: method `receive` has an incompatible type for trait [INFO] [stdout] --> src/actor/decorators.rs:37:38 [INFO] [stdout] | [INFO] [stdout] 37 | async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] | ^^^^^^^^^^^^ types differ in mutability [INFO] [stdout] | [INFO] [stdout] note: type in trait [INFO] [stdout] --> src/actor/mod.rs:22:38 [INFO] [stdout] | [INFO] [stdout] 22 | async fn receive(&mut self, ctx: &Context, msg: Message) -> Result<(), SendError>; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] = note: expected signature `fn(&'life0 mut RetryDecorator<_>, &'life1 context::context::Context, message::Message) -> Pin> + std::marker::Send + 'async_trait)>>` [INFO] [stdout] found signature `fn(&'life0 mut RetryDecorator<_>, &'life1 mut context::context::Context, message::Message) -> Pin + std::marker::Send + 'async_trait)>>` [INFO] [stdout] help: change the parameter type to match the trait [INFO] [stdout] | [INFO] [stdout] 37 - async fn receive(&mut self, ctx: &mut Context, msg: Message) { [INFO] [stdout] 37 + async fn receive(&mut self, ctx: &'life1 context::context::Context, msg: Message) { [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0049]: method `handle` has 1 type parameter but its trait declaration has 0 type parameters [INFO] [stdout] --> src/middleware/common.rs:14:1 [INFO] [stdout] | [INFO] [stdout] 14 | #[async_trait] [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] 15 | impl Middleware for LoggingMiddleware { [INFO] [stdout] 16 | async fn handle( [INFO] [stdout] | ^ [INFO] [stdout] 17 | &self, [INFO] [stdout] | ^ found 1 type parameter [INFO] [stdout] 18 | ctx: &mut Context, [INFO] [stdout] | ^ [INFO] [stdout] | [INFO] [stdout] ::: src/middleware/mod.rs:13:1 [INFO] [stdout] | [INFO] [stdout] 13 | #[async_trait] [INFO] [stdout] | -------------- [INFO] [stdout] 14 | pub trait Middleware: Send + Sync { [INFO] [stdout] 15 | async fn handle(&self, ctx: &mut Context, msg: Message, next: Next<'_>) -> Result<(), SendError>; [INFO] [stdout] | - - -- [INFO] [stdout] | | [INFO] [stdout] | expected 0 type parameters [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the attribute macro `async_trait` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0049]: method `handle` has 1 type parameter but its trait declaration has 0 type parameters [INFO] [stdout] --> src/middleware/common.rs:34:1 [INFO] [stdout] | [INFO] [stdout] 34 | #[async_trait] [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] 35 | impl Middleware for MetricsMiddleware { [INFO] [stdout] 36 | async fn handle( [INFO] [stdout] | ^ [INFO] [stdout] 37 | &self, [INFO] [stdout] | ^ found 1 type parameter [INFO] [stdout] 38 | ctx: &mut Context, [INFO] [stdout] | ^ [INFO] [stdout] | [INFO] [stdout] ::: src/middleware/mod.rs:13:1 [INFO] [stdout] | [INFO] [stdout] 13 | #[async_trait] [INFO] [stdout] | -------------- [INFO] [stdout] 14 | pub trait Middleware: Send + Sync { [INFO] [stdout] 15 | async fn handle(&self, ctx: &mut Context, msg: Message, next: Next<'_>) -> Result<(), SendError>; [INFO] [stdout] | - - -- [INFO] [stdout] | | [INFO] [stdout] | expected 0 type parameters [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the attribute macro `async_trait` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0049]: method `handle` has 1 type parameter but its trait declaration has 0 type parameters [INFO] [stdout] --> src/middleware/common.rs:61:1 [INFO] [stdout] | [INFO] [stdout] 61 | #[async_trait] [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] 62 | impl Middleware for RetryMiddleware { [INFO] [stdout] 63 | async fn handle( [INFO] [stdout] | ^ [INFO] [stdout] 64 | &self, [INFO] [stdout] | ^ found 1 type parameter [INFO] [stdout] 65 | ctx: &mut Context, [INFO] [stdout] | ^ [INFO] [stdout] | [INFO] [stdout] ::: src/middleware/mod.rs:13:1 [INFO] [stdout] | [INFO] [stdout] 13 | #[async_trait] [INFO] [stdout] | -------------- [INFO] [stdout] 14 | pub trait Middleware: Send + Sync { [INFO] [stdout] 15 | async fn handle(&self, ctx: &mut Context, msg: Message, next: Next<'_>) -> Result<(), SendError>; [INFO] [stdout] | - - -- [INFO] [stdout] | | [INFO] [stdout] | expected 0 type parameters [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the attribute macro `async_trait` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0049]: method `handle` has 1 type parameter but its trait declaration has 0 type parameters [INFO] [stdout] --> src/middleware/common.rs:91:1 [INFO] [stdout] | [INFO] [stdout] 91 | #[async_trait] [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] 92 | impl Middleware for CircuitBreakerMiddleware { [INFO] [stdout] 93 | async fn handle( [INFO] [stdout] | ^ [INFO] [stdout] 94 | &self, [INFO] [stdout] | ^ found 1 type parameter [INFO] [stdout] 95 | ctx: &mut Context, [INFO] [stdout] | ^ [INFO] [stdout] | [INFO] [stdout] ::: src/middleware/mod.rs:13:1 [INFO] [stdout] | [INFO] [stdout] 13 | #[async_trait] [INFO] [stdout] | -------------- [INFO] [stdout] 14 | pub trait Middleware: Send + Sync { [INFO] [stdout] 15 | async fn handle(&self, ctx: &mut Context, msg: Message, next: Next<'_>) -> Result<(), SendError>; [INFO] [stdout] | - - -- [INFO] [stdout] | | [INFO] [stdout] | expected 0 type parameters [INFO] [stdout] | [INFO] [stdout] = note: this error originates in the attribute macro `async_trait` (in Nightly builds, run with -Z macro-backtrace for more info) [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `CircuitBreakerState` [INFO] [stdout] --> src/middleware/common.rs:101:13 [INFO] [stdout] | [INFO] [stdout] 101 | CircuitBreakerState::Open => { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ use of undeclared type `CircuitBreakerState` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `CircuitBreakerState` [INFO] [stdout] --> src/middleware/common.rs:104:13 [INFO] [stdout] | [INFO] [stdout] 104 | CircuitBreakerState::HalfOpen => { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ use of undeclared type `CircuitBreakerState` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `CircuitBreakerState` [INFO] [stdout] --> src/middleware/common.rs:107:49 [INFO] [stdout] | [INFO] [stdout] 107 | *self.state.write().await = CircuitBreakerState::Closed; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ use of undeclared type `CircuitBreakerState` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `CircuitBreakerState` [INFO] [stdout] --> src/middleware/common.rs:109:49 [INFO] [stdout] | [INFO] [stdout] 109 | *self.state.write().await = CircuitBreakerState::Open; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ use of undeclared type `CircuitBreakerState` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `CircuitBreakerState` [INFO] [stdout] --> src/middleware/common.rs:113:13 [INFO] [stdout] | [INFO] [stdout] 113 | CircuitBreakerState::Closed => { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ use of undeclared type `CircuitBreakerState` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `SerializationError` [INFO] [stdout] --> src/remote/serialization.rs:46:55 [INFO] [stdout] | [INFO] [stdout] 46 | bincode::serialize(&envelope).map_err(|e| SerializationError::EncodingError(e.to_string())) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ use of undeclared type `SerializationError` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `SerializationError` [INFO] [stdout] --> src/remote/serialization.rs:48:17 [INFO] [stdout] | [INFO] [stdout] 48 | Err(SerializationError::NoSerializerFound(message_type)) [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ use of undeclared type `SerializationError` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `TcpConnection` [INFO] [stdout] --> src/remote/transport.rs:35:34 [INFO] [stdout] | [INFO] [stdout] 35 | let connection = TcpConnection::new(stream); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | use of undeclared type `TcpConnection` [INFO] [stdout] | help: a trait with a similar name exists: `Connection` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `TcpConnection` [INFO] [stdout] --> src/remote/transport.rs:49:21 [INFO] [stdout] | [INFO] [stdout] 49 | Ok(Box::new(TcpConnection::new(stream))) [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | use of undeclared type `TcpConnection` [INFO] [stdout] | help: a trait with a similar name exists: `Connection` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `DagBuilder` [INFO] [stdout] --> src/workflow/loader.rs:45:27 [INFO] [stdout] | [INFO] [stdout] 45 | let mut builder = DagBuilder::new(self.actor_factory.create_system()); [INFO] [stdout] | ^^^^^^^^^^ use of undeclared type `DagBuilder` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `Severity` [INFO] [stdout] --> src/workflow/quality.rs:21:39 [INFO] [stdout] | [INFO] [stdout] 21 | if result.severity >= Severity::High { [INFO] [stdout] | ^^^^^^^^ use of undeclared type `Severity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RecoveryPolicy` [INFO] [stdout] --> src/workflow/recovery.rs:10:13 [INFO] [stdout] | [INFO] [stdout] 10 | RecoveryPolicy::Retry { max_attempts, delay } => { [INFO] [stdout] | ^^^^^^^^^^^^^^ use of undeclared type `RecoveryPolicy` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RecoveryPolicy` [INFO] [stdout] --> src/workflow/recovery.rs:13:13 [INFO] [stdout] | [INFO] [stdout] 13 | RecoveryPolicy::Skip => { [INFO] [stdout] | ^^^^^^^^^^^^^^ use of undeclared type `RecoveryPolicy` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `RecoveryPolicy` [INFO] [stdout] --> src/workflow/recovery.rs:16:13 [INFO] [stdout] | [INFO] [stdout] 16 | RecoveryPolicy::Rollback => { [INFO] [stdout] | ^^^^^^^^^^^^^^ use of undeclared type `RecoveryPolicy` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0433]: failed to resolve: use of undeclared type `SchedulePlan` [INFO] [stdout] --> src/workflow/scheduler.rs:16:24 [INFO] [stdout] | [INFO] [stdout] 16 | let mut plan = SchedulePlan::new(); [INFO] [stdout] | ^^^^^^^^^^^^ use of undeclared type `SchedulePlan` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0049, E0053, E0107, E0405, E0412, E0422, E0432, E0433, E0603. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0049`. [INFO] [stdout] [INFO] [stderr] error: could not compile `protoactor` (lib) due to 118 previous errors; 13 warnings emitted [INFO] running `Command { std: "docker" "inspect" "c179c2a040cefce6498b60d2cb8fd41e562dc50fa174489d028bf0773404f18c", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "c179c2a040cefce6498b60d2cb8fd41e562dc50fa174489d028bf0773404f18c", kill_on_drop: false }` [INFO] [stdout] c179c2a040cefce6498b60d2cb8fd41e562dc50fa174489d028bf0773404f18c