diff --git a/hydro_lang/Cargo.toml b/hydro_lang/Cargo.toml index c102a46d01c..1a7fb564221 100644 --- a/hydro_lang/Cargo.toml +++ b/hydro_lang/Cargo.toml @@ -40,7 +40,6 @@ syn = { version = "2.0.46", features = [ "parsing", "extra-traits", "visit-mut" tokio = { version = "1.29.0", features = [ "full" ] } toml = { version = "0.8.0", optional = true } trybuild-internals-api = { version = "1.0.99", optional = true } -ctor = "0.2" [build-dependencies] stageleft_tool = { path = "../stageleft_tool", version = "^0.5.0" } @@ -48,6 +47,7 @@ stageleft_tool = { path = "../stageleft_tool", version = "^0.5.0" } [dev-dependencies] async-ssh2-lite = { version = "0.5.0", features = ["vendored-openssl"] } hydro_deploy = { path = "../hydro_deploy/core", version = "^0.11.0" } +ctor = "0.2" insta = "1.39" tokio-test = "0.4.4" trybuild = "1" diff --git a/hydro_lang/src/lib.rs b/hydro_lang/src/lib.rs index 2077923d22b..47c2a98fd38 100644 --- a/hydro_lang/src/lib.rs +++ b/hydro_lang/src/lib.rs @@ -46,12 +46,6 @@ mod staging_util; #[cfg(feature = "deploy")] pub mod test_util; -#[ctor::ctor] -fn add_private_reexports() { - stageleft::add_private_reexport(vec!["tokio", "time", "instant"], vec!["tokio", "time"]); - stageleft::add_private_reexport(vec!["bytes", "bytes"], vec!["bytes"]); -} - #[stageleft::runtime] #[cfg(test)] mod test_init { diff --git a/hydro_test/src/cluster/snapshots/hydro_test__cluster__paxos_bench__tests__paxos_ir.snap b/hydro_test/src/cluster/snapshots/hydro_test__cluster__paxos_bench__tests__paxos_ir.snap index c3b6cbc7bbf..b67ba161b10 100644 --- a/hydro_test/src/cluster/snapshots/hydro_test__cluster__paxos_bench__tests__paxos_ir.snap +++ b/hydro_test/src/cluster/snapshots/hydro_test__cluster__paxos_bench__tests__paxos_ir.snap @@ -778,11 +778,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 1, - Cluster( - 0, - ), + location_kind: Cluster( + 0, ), output_type: Some( hydro_test :: cluster :: paxos :: Ballot, @@ -790,11 +787,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 1, - Cluster( - 0, - ), + location_kind: Cluster( + 0, ), output_type: Some( (hydro_lang :: location :: cluster :: cluster_id :: ClusterId < hydro_test :: cluster :: paxos :: Acceptor > , hydro_test :: cluster :: paxos :: Ballot), @@ -1949,11 +1943,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 7, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( (hydro_lang :: location :: cluster :: cluster_id :: ClusterId < hydro_test :: cluster :: paxos :: Proposer > , hydro_test :: cluster :: kv_replica :: KvPayload < u32 , (hydro_lang :: location :: cluster :: cluster_id :: ClusterId < hydro_test :: cluster :: bench_client :: Client > , u32) >), @@ -4727,11 +4718,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 0, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( core :: time :: Duration, @@ -4739,11 +4727,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 0, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( core :: time :: Duration, @@ -4751,11 +4736,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 0, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( (std :: rc :: Rc < core :: cell :: RefCell < std :: vec :: Vec < core :: time :: Duration > > > , usize), @@ -4763,11 +4745,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 0, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( std :: rc :: Rc < core :: cell :: RefCell < std :: vec :: Vec < core :: time :: Duration > > >, @@ -4930,11 +4909,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 0, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( usize, @@ -4942,11 +4918,8 @@ expression: built.ir() }, }, metadata: HydroNodeMetadata { - location_kind: Tick( - 0, - Cluster( - 2, - ), + location_kind: Cluster( + 2, ), output_type: Some( (std :: rc :: Rc < core :: cell :: RefCell < std :: vec :: Vec < core :: time :: Duration > > > , usize), diff --git a/stageleft/src/type_name.rs b/stageleft/src/type_name.rs index dc02417d44c..19a4a011740 100644 --- a/stageleft/src/type_name.rs +++ b/stageleft/src/type_name.rs @@ -22,6 +22,8 @@ static PRIVATE_REEXPORTS: ReexportsSet = LazyLock::new(|| { vec!["std", "collections", "hash_set"], ), (vec!["std", "vec", "into_iter"], vec!["std", "vec"]), + (vec!["tokio", "time", "instant"], vec!["tokio", "time"]), + (vec!["bytes", "bytes"], vec!["bytes"]), ]) });