diff --git a/core/Cargo.toml b/core/Cargo.toml index aa38c92ba..622dd589a 100644 --- a/core/Cargo.toml +++ b/core/Cargo.toml @@ -33,7 +33,7 @@ enum_dispatch = "0.3" enum-iterator = "2" flate2 = { version = "1.0", optional = true } futures-util = { version = "0.3", default-features = false } -futures-channel = { version = "0.3", default-features = false } +futures-channel = { version = "0.3", default-features = false, features = ["std"]} governor = "0.6" http-body-util = { version = "0.1", optional = true } hyper = { version = "1.2", optional = true } diff --git a/tests/integ_tests/workflow_tests.rs b/tests/integ_tests/workflow_tests.rs index 1815cc749..c2f006330 100644 --- a/tests/integ_tests/workflow_tests.rs +++ b/tests/integ_tests/workflow_tests.rs @@ -18,7 +18,8 @@ mod upsert_search_attrs; use crate::integ_tests::{activity_functions::echo, metrics_tests}; use assert_matches::assert_matches; -use futures_util::{channel::mpsc::UnboundedReceiver, future, SinkExt, StreamExt}; +use futures_channel::mpsc::UnboundedReceiver; +use futures_util::{future, SinkExt, StreamExt}; use std::{ collections::{HashMap, HashSet}, sync::{ @@ -92,7 +93,7 @@ async fn parallel_workflows_same_queue() { let handles: Vec<_> = run_ids .iter() .map(|run_id| { - let (tx, rx) = futures_util::channel::mpsc::unbounded(); + let (tx, rx) = futures_channel::mpsc::unbounded(); send_chans.insert(run_id.clone(), tx); tokio::spawn(wf_task(core.clone(), rx)) })