Skip to content

Commit

Permalink
[controller] add/modify RepushJobResponse fields
Browse files Browse the repository at this point in the history
after studying information in Airflow response objects
  • Loading branch information
Whitney Deng committed Dec 12, 2024
1 parent 98171a5 commit 8253c82
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -110,10 +110,10 @@ public RepushJobResponse compactStore(String storeName) {
try {
RepushJobResponse response = repushOrchestrator.repush(storeName);
LOGGER.info(
"Repush job triggered for store: {} with job name: {} and job exec id: {}",
"Repush job triggered for store: {} | exec id: {} | exec url: {}",
response.getStoreName(),
response.getJobName(),
response.getJobExecId());
response.getExecId(),
response.getExecUrl());
return response;
} catch (Exception e) {
LOGGER.error("Failed to compact store: {}", storeName, e);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,32 +5,32 @@
*/
public class RepushJobResponse {
private final String storeName;
private final String jobName;
private final String jobExecId;
private final String jobExecUrl;
private final String execId;
private final String execUrl;
private final String execDate;

// TODO LC: airflow: storeName from conf, jobName from dag_id, jobExecId from dag_run_id

public RepushJobResponse(String storeName, String jobName, String jobId, String jobExecUrl) {
public RepushJobResponse(String storeName, String jobName, String jobId, String jobExecUrl, String execDate) {
this.storeName = storeName;
this.jobName = jobName;
this.jobExecId = jobId;
this.jobExecUrl = jobExecUrl;
this.execId = jobId;
this.execUrl = jobExecUrl;
this.execDate = execDate;
}

public String getStoreName() {
return storeName;
}

public String getJobName() {
return jobName;
public String getExecId() {
return execId;
}

public String getJobExecId() {
return jobExecId;
public String getExecUrl() {
return execUrl;
}

public String getJobExecUrl() {
return jobExecUrl;
public String getExecDate() {
return execDate;
}
}

0 comments on commit 8253c82

Please sign in to comment.