This is an automated email from the ASF dual-hosted git repository.
milenkovicm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new 400f818c do not panic if using alternate temp dir (#1332)
400f818c is described below
commit 400f818ccd84126ae1733cf6457c592c542d0b63
Author: David Stancu <[email protected]>
AuthorDate: Fri Oct 24 09:21:32 2025 -0400
do not panic if using alternate temp dir (#1332)
---
ballista/executor/src/executor_process.rs | 14 ++++++++++----
1 file changed, 10 insertions(+), 4 deletions(-)
diff --git a/ballista/executor/src/executor_process.rs
b/ballista/executor/src/executor_process.rs
index 3d67fd61..d365f3cb 100644
--- a/ballista/executor/src/executor_process.rs
+++ b/ballista/executor/src/executor_process.rs
@@ -163,10 +163,16 @@ pub async fn start_executor_process(
let scheduler_port = opt.scheduler_port;
let scheduler_url = format!("http://{scheduler_host}:{scheduler_port}";);
- let work_dir = opt
- .work_dir
- .clone()
- .unwrap_or(TempDir::new()?.path().to_str().unwrap().to_string());
+ let work_dir = if let Some(work_dir) = opt.work_dir.clone() {
+ work_dir
+ } else if let Some(temp_dir) =
TempDir::new()?.path().to_str().map(ToOwned::to_owned)
+ {
+ temp_dir
+ } else {
+ return Err(BallistaError::Configuration(
+ "Unable to bind work dir".to_string(),
+ ));
+ };
let concurrent_tasks = if opt.concurrent_tasks == 0 {
// use all available cores if no concurrency level is specified
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
