feat(models): Add edges fields to data process instance relationship aspects

Author: asikowitz

metadata-models/src/main/pegasus/com/linkedin/dataprocess/DataProcessInstanceInput.pdl

@@ -1,5 +1,6 @@
 namespace com.linkedin.dataprocess
 
+import com.linkedin.common.Edge
 import com.linkedin.common.Urn
 
 /**
@@ -15,8 +16,7 @@ record DataProcessInstanceInput {
   @Relationship = {
     "/*": {
       "name": "Consumes",
-      "entityTypes": [ "dataset", "mlModel"],
-      "isLineage": true
+      "entityTypes": [ "dataset", "mlModel" ]
     }
   }
   @Searchable = {
@@ -29,4 +29,23 @@ record DataProcessInstanceInput {
     }
   }
   inputs: array[Urn]
+
+  /**
+   * Input assets consumed by the data process instance, with additional metadata.
+   * Counts as lineage.
+   * Will eventually deprecate the inputs field.
+   */
+  @Relationship = {
+    "/*/destinationUrn": {
+      "name": "DataProcessInstanceConsumes",
+      "entityTypes": [ "dataset", "mlModel" ],
+      "isLineage": true,
+      "createdOn": "inputEdges/*/created/time"
+      "createdActor": "inputEdges/*/created/actor"
+      "updatedOn": "inputEdges/*/lastModified/time"
+      "updatedActor": "inputEdges/*/lastModified/actor"
+      "properties": "inputEdges/*/properties"
+    }
+  }
+  inputEdges: array[Edge]
 }

metadata-models/src/main/pegasus/com/linkedin/dataprocess/DataProcessInstanceOutput.pdl

@@ -10,14 +10,12 @@ import com.linkedin.common.Urn
 }
 record DataProcessInstanceOutput {
   /**
-   * Output datasets to be produced
+   * Output assets produced
    */
   @Relationship = {
     "/*": {
       "name": "Produces",
-      "entityTypes": [ "dataset", "mlModel" ],
-      "isLineage": true,
-      "isUpstream": false
+      "entityTypes": [ "dataset", "mlModel" ]
     }
   }
   @Searchable = {
@@ -31,4 +29,23 @@ record DataProcessInstanceOutput {
   }
   outputs: array[Urn]
 
+  /**
+   * Output assets produced by the data process instance during processing, with additional metadata.
+   * Counts as lineage.
+   * Will eventually deprecate the outputs field.
+   */
+  @Relationship = {
+    "/*/destinationUrn": {
+      "name": "DataProcessInstanceProduces",
+      "entityTypes": [ "dataset", "mlModel" ],
+      "isUpstream": false,
+      "isLineage": true,
+      "createdOn": "outputEdges/*/created/time"
+      "createdActor": "outputEdges/*/created/actor"
+      "updatedOn": "outputEdges/*/lastModified/time"
+      "updatedActor": "outputEdges/*/lastModified/actor"
+      "properties": "outputEdges/*/properties"
+    }
+  }
+  outputEdges: array[Edge]
 }