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 939d73df0 feat: [REST] Return the job's start and end time (#1511)
939d73df0 is described below
commit 939d73df0b83216ac7a23a2326a9f6d2952008fa
Author: Martin Grigorov <[email protected]>
AuthorDate: Mon Mar 16 10:06:08 2026 +0200
feat: [REST] Return the job's start and end time (#1511)
---
ballista/scheduler/src/api/handlers.rs | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/ballista/scheduler/src/api/handlers.rs
b/ballista/scheduler/src/api/handlers.rs
index 3cf1f79a6..1d79a5228 100644
--- a/ballista/scheduler/src/api/handlers.rs
+++ b/ballista/scheduler/src/api/handlers.rs
@@ -69,6 +69,10 @@ pub struct JobResponse {
pub num_stages: usize,
pub completed_stages: usize,
pub percent_complete: u8,
+ /// Timestamp when the job started.
+ pub start_time: u64,
+ /// Timestamp when the job ended (0 if still running).
+ pub end_time: u64,
#[serde(skip_serializing_if = "Option::is_none")]
pub logical_plan: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
@@ -176,6 +180,8 @@ pub async fn get_jobs<
job_name: job.job_name.to_string(),
job_status,
status: plain_status,
+ start_time: job.start_time,
+ end_time: job.end_time,
num_stages: job.num_stages,
completed_stages: job.completed_stages,
percent_complete,
@@ -221,6 +227,8 @@ pub async fn get_job<
job_name: job.job_name().to_string(),
job_status,
status: plain_status,
+ start_time: job.start_time(),
+ end_time: job.end_time(),
num_stages,
completed_stages,
percent_complete,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
