From 8253c82dce9cea7c4fe215ac5363022ee0a6038c Mon Sep 17 00:00:00 2001
From: Whitney Deng <whdeng@linkedin.com>
Date: Thu, 12 Dec 2024 09:39:02 -0800
Subject: [PATCH] [controller] add/modify RepushJobResponse fields

after studying information in Airflow response objects
---
 .../logcompaction/CompactionManager.java      |  6 ++---
 .../controller/repush/RepushJobResponse.java  | 26 +++++++++----------
 2 files changed, 16 insertions(+), 16 deletions(-)

diff --git a/services/venice-controller/src/main/java/com/linkedin/venice/controller/logcompaction/CompactionManager.java b/services/venice-controller/src/main/java/com/linkedin/venice/controller/logcompaction/CompactionManager.java
index 5ee6314447..5aa39363f7 100644
--- a/services/venice-controller/src/main/java/com/linkedin/venice/controller/logcompaction/CompactionManager.java
+++ b/services/venice-controller/src/main/java/com/linkedin/venice/controller/logcompaction/CompactionManager.java
@@ -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);
diff --git a/services/venice-controller/src/main/java/com/linkedin/venice/controller/repush/RepushJobResponse.java b/services/venice-controller/src/main/java/com/linkedin/venice/controller/repush/RepushJobResponse.java
index 51ece03784..00dfe72d43 100644
--- a/services/venice-controller/src/main/java/com/linkedin/venice/controller/repush/RepushJobResponse.java
+++ b/services/venice-controller/src/main/java/com/linkedin/venice/controller/repush/RepushJobResponse.java
@@ -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;
   }
 }