File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -33,7 +33,7 @@ pub enum Context {
33
33
impl Context {
34
34
/// create a new remote context with given host and port
35
35
pub async fn new_remote ( host : & str , port : u16 ) -> Result < Context > {
36
- Ok ( Context :: Remote ( BallistaContext :: try_new ( host, port) ?) )
36
+ Ok ( Context :: Remote ( BallistaContext :: try_new ( host, port) . await ?) )
37
37
}
38
38
39
39
/// create a local context using the given config
@@ -61,7 +61,7 @@ impl BallistaContext {
61
61
use ballista:: prelude:: BallistaConfig ;
62
62
let config: BallistaConfig = BallistaConfig :: new ( )
63
63
. map_err ( |e| DataFusionError :: Execution ( format ! ( "{:?}" , e) ) ) ?;
64
- BallistaContext :: remote ( host, port, & config) . await
64
+ Ok ( Self ( BallistaContext :: remote ( host, port, & config) . await ? ) )
65
65
}
66
66
67
67
pub async fn sql ( & mut self , sql : & str ) -> Result < Arc < dyn DataFrame > > {
You can’t perform that action at this time.
0 commit comments