| @@ -269,7 +269,7 @@ pub async fn spawn_node( | |||||
| "-n", | "-n", | ||||
| conda_env, | conda_env, | ||||
| "python", | "python", | ||||
| "-c", | |||||
| "-uc", | |||||
| format!("import dora; dora.start_runtime() # {}", node.id).as_str(), | format!("import dora; dora.start_runtime() # {}", node.id).as_str(), | ||||
| ]); | ]); | ||||
| command | command | ||||
| @@ -295,7 +295,7 @@ pub async fn spawn_node( | |||||
| }; | }; | ||||
| // Force python to always flush stdout/stderr buffer | // Force python to always flush stdout/stderr buffer | ||||
| cmd.args([ | cmd.args([ | ||||
| "-c", | |||||
| "-uc", | |||||
| format!("import dora; dora.start_runtime() # {}", node.id).as_str(), | format!("import dora; dora.start_runtime() # {}", node.id).as_str(), | ||||
| ]); | ]); | ||||
| cmd | cmd | ||||
| @@ -323,7 +323,7 @@ pub async fn spawn_node( | |||||
| ); | ); | ||||
| cmd.args([ | cmd.args([ | ||||
| "-c", | |||||
| "-uc", | |||||
| format!("import dora; dora.start_runtime() # {}", node.id).as_str(), | format!("import dora; dora.start_runtime() # {}", node.id).as_str(), | ||||
| ]); | ]); | ||||
| cmd | cmd | ||||
| @@ -336,7 +336,10 @@ pub async fn spawn_node( | |||||
| cmd | cmd | ||||
| } | } | ||||
| } else { | } else { | ||||
| bail!("Could not figure out dora installation. Could you try to reinstall dora or run it with `dora` command?"); | |||||
| bail!( | |||||
| "Cannot spawn runtime with both Python and non-Python operators. \ | |||||
| Please use a single operator or ensure that all operators are Python-based." | |||||
| ); | |||||
| }; | }; | ||||
| command.current_dir(working_dir); | command.current_dir(working_dir); | ||||