Skip to content

Commit c615fce

Browse files
Add queued and completed timestamps to successful job status
1 parent 24d4830 commit c615fce

File tree

3 files changed

+5
-0
lines changed

3 files changed

+5
-0
lines changed

ballista/core/proto/ballista.proto

+2
Original file line numberDiff line numberDiff line change
@@ -904,6 +904,8 @@ message GetJobStatusParams {
904904

905905
message SuccessfulJob {
906906
repeated PartitionLocation partition_location = 1;
907+
uint64 queued_at = 2;
908+
uint64 completed_at = 3;
907909
}
908910

909911
message QueuedJob {}

ballista/scheduler/src/scheduler_server/mod.rs

+1
Original file line numberDiff line numberDiff line change
@@ -498,6 +498,7 @@ mod test {
498498
match status.status {
499499
Some(job_status::Status::Successful(SuccessfulJob {
500500
partition_location,
501+
..
501502
})) => {
502503
assert_eq!(partition_location.len(), 4);
503504
}

ballista/scheduler/src/state/execution_graph.rs

+2
Original file line numberDiff line numberDiff line change
@@ -1235,6 +1235,8 @@ impl ExecutionGraph {
12351235
self.status = JobStatus {
12361236
status: Some(job_status::Status::Successful(SuccessfulJob {
12371237
partition_location,
1238+
queued_at: self.queued_at,
1239+
completed_at: timestamp_millis(),
12381240
})),
12391241
};
12401242
self.end_time = SystemTime::now()

0 commit comments

Comments
 (0)