Skip to content

Commit

Permalink
feat(optimus): add GetDeployJobsStatus (#132)
Browse files Browse the repository at this point in the history
* feat(optimus): add GetDeployJobsStatus

* fix(optimus): change success field to status in GetDeployJobsStatusResponse

* refactor(optimus): remove unused total_failure field from GetDeployJobsStatusResponse

* fix(optimus): include success_count and failure_count in GetDeployJobsStatusResponse

* fix(optimus): change index of failure_count in GetDeployJobsStatusResponse
  • Loading branch information
arinda-arif authored Apr 27, 2022
1 parent 5d6ac6b commit 63458a3
Showing 1 changed file with 22 additions and 2 deletions.
24 changes: 22 additions & 2 deletions odpf/optimus/core/v1beta1/job_spec.proto
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,11 @@ service JobSpecificationService {

// RefreshJobs do redeployment using the current persisted state.
// It will returns a stream of messages which can be used to track the progress.
// Message containing ack are status events other are progress events
rpc RefreshJobs(RefreshJobsRequest) returns (stream RefreshJobsResponse) {}

// GetDeployJobsStatus check status of job deployment.
// It will returns status of the job deployment and the failure details.
rpc GetDeployJobsStatus(GetDeployJobsStatusRequest) returns (GetDeployJobsStatusResponse) {}
}

message DeployJobSpecificationRequest {
Expand Down Expand Up @@ -276,7 +279,24 @@ message RefreshJobsResponse {

// response type differentiate events
string type = 2;
string message = 3;
string value = 3;

string job_name = 4;
}

message GetDeployJobsStatusRequest {
string deploy_id = 1;
}

message GetDeployJobsStatusResponse {
string status = 1;

repeated DeployJobFailure failures = 2;
int32 success_count = 3;
int32 failure_count = 4;
}

message DeployJobFailure {
string job_name = 1;
string message = 2;
}

0 comments on commit 63458a3

Please sign in to comment.