Skip to content
This repository has been archived by the owner on Oct 23, 2023. It is now read-only.

Pass dynamic workflow closure in node execution events #141

Merged
merged 3 commits into from
Apr 13, 2021
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion gen/pb-cpp/flyteidl/admin/event.pb.cc

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

626 changes: 559 additions & 67 deletions gen/pb-cpp/flyteidl/admin/node_execution.pb.cc

Large diffs are not rendered by default.

285 changes: 282 additions & 3 deletions gen/pb-cpp/flyteidl/admin/node_execution.pb.h

Large diffs are not rendered by default.

650 changes: 570 additions & 80 deletions gen/pb-cpp/flyteidl/event/event.pb.cc

Large diffs are not rendered by default.

293 changes: 286 additions & 7 deletions gen/pb-cpp/flyteidl/event/event.pb.h

Large diffs are not rendered by default.

200 changes: 135 additions & 65 deletions gen/pb-go/flyteidl/admin/node_execution.pb.go

Large diffs are not rendered by default.

100 changes: 100 additions & 0 deletions gen/pb-go/flyteidl/admin/node_execution.pb.validate.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

231 changes: 151 additions & 80 deletions gen/pb-go/flyteidl/event/event.pb.go

Large diffs are not rendered by default.

100 changes: 100 additions & 0 deletions gen/pb-go/flyteidl/event/event.pb.validate.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

34 changes: 34 additions & 0 deletions gen/pb-go/flyteidl/service/admin.swagger.json
Original file line number Diff line number Diff line change
Expand Up @@ -3812,6 +3812,9 @@
},
"task_node_metadata": {
"$ref": "#/definitions/flyteidladminTaskNodeMetadata"
},
"dynamic_workflow_node_metadata": {
"$ref": "#/definitions/flyteidladminDynamicWorkflowNodeMetadata"
}
},
"description": "Container for node execution details and results."
Expand Down Expand Up @@ -5930,6 +5933,9 @@
"task_node_metadata": {
"$ref": "#/definitions/flyteidleventTaskNodeMetadata"
},
"dynamic_workflow_node_metadata": {
"$ref": "#/definitions/flyteidleventDynamicWorkflowNodeMetadata"
},
"parent_task_metadata": {
"$ref": "#/definitions/eventParentTaskExecutionMetadata",
"description": "[To be deprecated] Specifies which task (if any) launched this node."
Expand Down Expand Up @@ -6115,6 +6121,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": {
Expand Down Expand Up @@ -6195,6 +6215,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": {
Expand Down
2 changes: 2 additions & 0 deletions gen/pb-go/flyteidl/service/flyteadmin/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Loading