Extend Status of Pipeline CRD to include Mapping of External Jobs (#158)

Co-authored-by: Shrinand Thakkar <sthakkar@linkedin.com>

Author: srnand

hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/models/V1alpha1Pipeline.java

@@ -31,7 +31,7 @@
  * A set of objects that work together to deliver data.
  */
 @ApiModel(description = "A set of objects that work together to deliver data.")
-@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-05-21T02:31:00.123Z[Etc/UTC]")
+@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-08-12T17:02:58.557Z[Etc/UTC]")
 public class V1alpha1Pipeline implements io.kubernetes.client.common.KubernetesObject {
   public static final String SERIALIZED_NAME_API_VERSION = "apiVersion";
   @SerializedName(SERIALIZED_NAME_API_VERSION)

hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/models/V1alpha1PipelineList.java

@@ -32,7 +32,7 @@
  * PipelineList is a list of Pipeline
  */
 @ApiModel(description = "PipelineList is a list of Pipeline")
-@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-05-21T02:31:00.123Z[Etc/UTC]")
+@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-08-12T17:02:58.557Z[Etc/UTC]")
 public class V1alpha1PipelineList implements io.kubernetes.client.common.KubernetesListObject {
   public static final String SERIALIZED_NAME_API_VERSION = "apiVersion";
   @SerializedName(SERIALIZED_NAME_API_VERSION)

hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/models/V1alpha1PipelineSpec.java

@@ -28,7 +28,7 @@
  * Pipeline spec.
  */
 @ApiModel(description = "Pipeline spec.")
-@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-05-21T02:31:00.123Z[Etc/UTC]")
+@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-08-12T17:02:58.557Z[Etc/UTC]")
 public class V1alpha1PipelineSpec {
   public static final String SERIALIZED_NAME_SQL = "sql";
   @SerializedName(SERIALIZED_NAME_SQL)

hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/models/V1alpha1PipelineStatus.java

@@ -23,17 +23,24 @@
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import java.io.IOException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  * Pipeline status.
  */
 @ApiModel(description = "Pipeline status.")
-@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-05-21T02:31:00.123Z[Etc/UTC]")
+@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2025-08-12T17:02:58.557Z[Etc/UTC]")
 public class V1alpha1PipelineStatus {
   public static final String SERIALIZED_NAME_FAILED = "failed";
   @SerializedName(SERIALIZED_NAME_FAILED)
   private Boolean failed;
 
+  public static final String SERIALIZED_NAME_JOBS = "jobs";
+  @SerializedName(SERIALIZED_NAME_JOBS)
+  private Map<String, Map<String, String>> jobs = null;
+
   public static final String SERIALIZED_NAME_MESSAGE = "message";
   @SerializedName(SERIALIZED_NAME_MESSAGE)
   private String message;
@@ -66,6 +73,37 @@ public void setFailed(Boolean failed) {
   }
 
 
+  public V1alpha1PipelineStatus jobs(Map<String, Map<String, String>> jobs) {
+    
+    this.jobs = jobs;
+    return this;
+  }
+
+  public V1alpha1PipelineStatus putJobsItem(String key, Map<String, String> jobsItem) {
+    if (this.jobs == null) {
+      this.jobs = new HashMap<>();
+    }
+    this.jobs.put(key, jobsItem);
+    return this;
+  }
+
+   /**
+   * External jobs that this pipeline triggers.
+   * @return jobs
+  **/
+  @javax.annotation.Nullable
+  @ApiModelProperty(value = "External jobs that this pipeline triggers.")
+
+  public Map<String, Map<String, String>> getJobs() {
+    return jobs;
+  }
+
+
+  public void setJobs(Map<String, Map<String, String>> jobs) {
+    this.jobs = jobs;
+  }
+
+
   public V1alpha1PipelineStatus message(String message) {
 
     this.message = message;
@@ -122,13 +160,14 @@ public boolean equals(Object o) {
     }
     V1alpha1PipelineStatus v1alpha1PipelineStatus = (V1alpha1PipelineStatus) o;
     return Objects.equals(this.failed, v1alpha1PipelineStatus.failed) &&
+        Objects.equals(this.jobs, v1alpha1PipelineStatus.jobs) &&
         Objects.equals(this.message, v1alpha1PipelineStatus.message) &&
         Objects.equals(this.ready, v1alpha1PipelineStatus.ready);
   }
 
   @Override
   public int hashCode() {
-    return Objects.hash(failed, message, ready);
+    return Objects.hash(failed, jobs, message, ready);
   }
 
 
@@ -137,6 +176,7 @@ public String toString() {
     StringBuilder sb = new StringBuilder();
     sb.append("class V1alpha1PipelineStatus {\n");
     sb.append("    failed: ").append(toIndentedString(failed)).append("\n");
+    sb.append("    jobs: ").append(toIndentedString(jobs)).append("\n");
     sb.append("    message: ").append(toIndentedString(message)).append("\n");
     sb.append("    ready: ").append(toIndentedString(ready)).append("\n");
     sb.append("}");

hoptimator-k8s/src/main/resources/pipelines.crd.yaml

@@ -53,6 +53,14 @@ spec:
                 message:
                   description: Error or success message, for information only.
                   type: string
+                jobs:
+                  type: object
+                  description: External jobs that this pipeline triggers.
+                  additionalProperties:
+                    type: object
+                    description: Properties of the job.
+                    additionalProperties:
+                      type: string
       subresources:
         status: {}
       additionalPrinterColumns: