Pass dynamic workflow closure in node execution events

gen/pb-go/flyteidl/service/admin.swagger.json

@@ -6115,6 +6115,20 @@
         }
       }
     },
+    "flyteidladminDynamicWorkflowNodeMetadata": {
+      "type": "object",
+      "properties": {
+        "id": {
+          "$ref": "#/definitions/coreIdentifier",
+          "description": "id represents the unique identifier of the workflow."
+        },
+        "compiled_workflow": {
+          "$ref": "#/definitions/coreCompiledWorkflowClosure",
+          "description": "Represents the compiled representation of the embedded dynamic workflow."
+        }
+      },
+      "description": "For dynamic workflow nodes we send information about the dynamic workflow definition that gets generated."
+    },
     "flyteidladminNodeExecution": {
       "type": "object",
       "properties": {
@@ -6170,6 +6184,10 @@
         "catalog_key": {
           "$ref": "#/definitions/coreCatalogMetadata",
           "title": "This structure carries the catalog artifact information"
+        },
+        "dynamic_workflow_node_metadata": {
+          "$ref": "#/definitions/flyteidladminDynamicWorkflowNodeMetadata",
+          "description": "In the case this task launched a dynamic workflow we capture its structure here."
         }
       },
       "title": "Metadata for the case in which the node is a TaskNode"
@@ -6195,6 +6213,20 @@
       },
       "description": "A strongly typed schema that defines the interface of data retrieved from the underlying storage medium."
     },
+    "flyteidleventDynamicWorkflowNodeMetadata": {
+      "type": "object",
+      "properties": {
+        "id": {
+          "$ref": "#/definitions/coreIdentifier",
+          "description": "id represents the unique identifier of the workflow."
+        },
+        "compiled_workflow": {
+          "$ref": "#/definitions/coreCompiledWorkflowClosure",
+          "description": "Represents the compiled representation of the embedded dynamic workflow."
+        }
+      },
+      "description": "For dynamic workflow nodes we send information about the dynamic workflow definition that gets generated."
+    },
     "flyteidleventTaskNodeMetadata": {
       "type": "object",
       "properties": {
@@ -6205,6 +6237,10 @@
         "catalog_key": {
           "$ref": "#/definitions/coreCatalogMetadata",
           "title": "This structure carries the catalog artifact information"
+        },
+        "dynamic_workflow_node_metadata": {
+          "$ref": "#/definitions/flyteidleventDynamicWorkflowNodeMetadata",
+          "description": "In the case this task launched a dynamic workflow we capture its structure here."
         }
       }
     },

gen/pb-go/flyteidl/service/flyteadmin/README.md

@@ -266,11 +266,13 @@ Class | Method | HTTP request | Description
  - [EventWorkflowExecutionEvent](docs/EventWorkflowExecutionEvent.md)
  - [ExecutionErrorErrorKind](docs/ExecutionErrorErrorKind.md)
  - [ExecutionMetadataExecutionMode](docs/ExecutionMetadataExecutionMode.md)
+ - [FlyteidladminDynamicWorkflowNodeMetadata](docs/FlyteidladminDynamicWorkflowNodeMetadata.md)
  - [FlyteidladminNodeExecution](docs/FlyteidladminNodeExecution.md)
  - [FlyteidladminTaskExecution](docs/FlyteidladminTaskExecution.md)
  - [FlyteidladminTaskNodeMetadata](docs/FlyteidladminTaskNodeMetadata.md)
  - [FlyteidladminWorkflowNodeMetadata](docs/FlyteidladminWorkflowNodeMetadata.md)
  - [FlyteidlcoreSchema](docs/FlyteidlcoreSchema.md)
+ - [FlyteidleventDynamicWorkflowNodeMetadata](docs/FlyteidleventDynamicWorkflowNodeMetadata.md)
  - [FlyteidleventTaskNodeMetadata](docs/FlyteidleventTaskNodeMetadata.md)
  - [FlyteidleventWorkflowNodeMetadata](docs/FlyteidleventWorkflowNodeMetadata.md)
  - [IoStrategyDownloadMode](docs/IoStrategyDownloadMode.md)