@@ -4,11 +4,6 @@ use std::sync::Arc;
44
55use warp:: { Filter , Rejection , Reply } ;
66
7- use cubeshared:: codegen:: {
8- root_as_http_message, HttpColumnValue , HttpColumnValueArgs , HttpError , HttpErrorArgs ,
9- HttpMessageArgs , HttpQuery , HttpQueryArgs , HttpResultSet , HttpResultSetArgs , HttpRow ,
10- HttpRowArgs ,
11- } ;
127use crate :: metastore:: { Column , ColumnType , ImportFormat } ;
138use crate :: mysql:: SqlAuthService ;
149use crate :: sql:: { InlineTable , InlineTables , SqlQueryContext , SqlService } ;
@@ -17,6 +12,11 @@ use crate::table::{Row, TableValue};
1712use crate :: util:: WorkerLoop ;
1813use crate :: CubeError ;
1914use async_std:: fs:: File ;
15+ use cubeshared:: codegen:: {
16+ root_as_http_message, HttpColumnValue , HttpColumnValueArgs , HttpError , HttpErrorArgs ,
17+ HttpMessageArgs , HttpQuery , HttpQueryArgs , HttpResultSet , HttpResultSetArgs , HttpRow ,
18+ HttpRowArgs ,
19+ } ;
2020use datafusion:: cube_ext;
2121use flatbuffers:: { FlatBufferBuilder , ForwardsUOffset , Vector , WIPOffset } ;
2222use futures:: { AsyncWriteExt , SinkExt , Stream , StreamExt } ;
@@ -857,7 +857,6 @@ impl HttpMessage {
857857
858858#[ cfg( test) ]
859859mod tests {
860- use cubeshared:: codegen:: { HttpMessageArgs , HttpQuery , HttpQueryArgs , HttpTable , HttpTableArgs } ;
861860 use crate :: config:: { init_test_logger, Config } ;
862861 use crate :: http:: { HttpCommand , HttpMessage , HttpServer } ;
863862 use crate :: metastore:: { Column , ColumnType } ;
@@ -867,6 +866,9 @@ mod tests {
867866 use crate :: table:: { Row , TableValue } ;
868867 use crate :: CubeError ;
869868 use async_trait:: async_trait;
869+ use cubeshared:: codegen:: {
870+ HttpMessageArgs , HttpQuery , HttpQueryArgs , HttpTable , HttpTableArgs ,
871+ } ;
870872 use datafusion:: cube_ext;
871873 use flatbuffers:: { FlatBufferBuilder , ForwardsUOffset , Vector , WIPOffset } ;
872874 use futures_util:: { SinkExt , StreamExt } ;
0 commit comments