@@ -99,9 +99,7 @@ pub fn stage_from_proto(
9999}
100100
101101// add tests for round trip to and from a proto message for ExecutionStage
102- /* TODO: broken for now
103102#[ cfg( test) ]
104-
105103mod tests {
106104 use std:: sync:: Arc ;
107105
@@ -110,19 +108,13 @@ mod tests {
110108 array:: { RecordBatch , StringArray , UInt8Array } ,
111109 datatypes:: { DataType , Field , Schema } ,
112110 } ,
113- catalog::memory::DataSourceExec,
114- common::{internal_datafusion_err, internal_err},
111+ common:: internal_datafusion_err,
115112 datasource:: MemTable ,
116- error::{DataFusionError, Result} ,
113+ error:: Result ,
117114 execution:: context:: SessionContext ,
118- prelude::SessionConfig,
119- };
120- use datafusion_proto::{
121- physical_plan::{AsExecutionPlan, DefaultPhysicalExtensionCodec},
122- protobuf::PhysicalPlanNode,
123115 } ;
116+ use datafusion_proto:: physical_plan:: DefaultPhysicalExtensionCodec ;
124117 use prost:: Message ;
125- use uuid::Uuid;
126118
127119 use crate :: stage:: { proto:: stage_from_proto, ExecutionStage , ExecutionStageProto } ;
128120
@@ -147,6 +139,7 @@ mod tests {
147139 }
148140
149141 #[ tokio:: test]
142+ #[ ignore]
150143 async fn test_execution_stage_proto_round_trip ( ) -> Result < ( ) > {
151144 let ctx = SessionContext :: new ( ) ;
152145 let mem_table = create_mem_table ( ) ;
@@ -195,4 +188,4 @@ mod tests {
195188 assert_eq ! ( stage. name, round_trip_stage. name) ;
196189 Ok ( ( ) )
197190 }
198- }*/
191+ }
0 commit comments