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 2fccbfa2f Add plain "status" field to the JobResponse (#1497)
2fccbfa2f is described below
commit 2fccbfa2f963d535e17ca38cdb7cf92a75de2b63
Author: Martin Grigorov <[email protected]>
AuthorDate: Tue Mar 10 17:35:21 2026 +0200
Add plain "status" field to the JobResponse (#1497)
The old "job_status" is more like a status description with some extra
information.
The plain "status" field just gives one of: Running, Queued, Completed
or Failed
---
ballista/scheduler/src/api/handlers.rs | 14 +++++++++-----
1 file changed, 9 insertions(+), 5 deletions(-)
diff --git a/ballista/scheduler/src/api/handlers.rs
b/ballista/scheduler/src/api/handlers.rs
index c1bf42bab..de1546c59 100644
--- a/ballista/scheduler/src/api/handlers.rs
+++ b/ballista/scheduler/src/api/handlers.rs
@@ -52,6 +52,7 @@ pub struct JobResponse {
pub job_id: String,
pub job_name: String,
pub job_status: String,
+ pub status: String,
pub num_stages: usize,
pub completed_stages: usize,
pub percent_complete: u8,
@@ -129,10 +130,10 @@ pub async fn get_jobs<
.iter()
.map(|job| {
let status = &job.status;
- let job_status = match &status.status {
- Some(Status::Queued(_)) => "Queued".to_string(),
- Some(Status::Running(_)) => "Running".to_string(),
- Some(Status::Failed(error)) => format!("Failed: {}",
error.error),
+ let (plain_status, job_status) = match &status.status {
+ Some(Status::Queued(_)) => ("Queued".to_string(),
"Queued".to_string()),
+ Some(Status::Running(_)) => ("Running".to_string(),
"Running".to_string()),
+ Some(Status::Failed(error)) => ("Failed".to_string(),
format!("Failed: {}", error.error)),
Some(Status::Successful(completed)) => {
let num_rows = completed
.partition_location
@@ -148,13 +149,15 @@ pub async fn get_jobs<
} else {
"partitions"
};
+ ("Completed".to_string(),
format!(
"Completed. Produced {} {} containing {} {}. Elapsed
time: {} ms.",
num_partitions, num_partitions_term, num_rows,
num_rows_term,
job.end_time - job.start_time
)
+ )
}
- _ => "Invalid State".to_string(),
+ _ => ("Invalid".to_string(), "Invalid State".to_string()),
};
// calculate progress based on completed stages for now, but we
could use completed
@@ -165,6 +168,7 @@ pub async fn get_jobs<
job_id: job.job_id.to_string(),
job_name: job.job_name.to_string(),
job_status,
+ status: plain_status,
num_stages: job.num_stages,
completed_stages: job.completed_stages,
percent_complete,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
