Add K8sPod as a task target option (#172)

flyteorg · May 26, 2021 · 868de79 · 868de79
1 parent 1934f0c
commit 868de79
Show file tree

Hide file tree

Showing 29 changed files with 6,483 additions and 319 deletions.
diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/task.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/task.pb.cc
diff --git a/flyteidl/gen/pb-cpp/flyteidl/core/compiler.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/core/compiler.pb.cc
diff --git a/flyteidl/gen/pb-cpp/flyteidl/core/dynamic_job.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/core/dynamic_job.pb.cc
diff --git a/flyteidl/gen/pb-cpp/flyteidl/core/tasks.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/core/tasks.pb.cc
diff --git a/flyteidl/gen/pb-cpp/flyteidl/core/tasks.pb.h b/flyteidl/gen/pb-cpp/flyteidl/core/tasks.pb.h
diff --git a/flyteidl/gen/pb-cpp/flyteidl/core/workflow_closure.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/core/workflow_closure.pb.cc
diff --git a/flyteidl/gen/pb-go/flyteidl/core/tasks.pb.go b/flyteidl/gen/pb-go/flyteidl/core/tasks.pb.go
diff --git a/flyteidl/gen/pb-go/flyteidl/core/tasks.pb.validate.go b/flyteidl/gen/pb-go/flyteidl/core/tasks.pb.validate.go
diff --git a/flyteidl/gen/pb-go/flyteidl/service/admin.swagger.json b/flyteidl/gen/pb-go/flyteidl/service/admin.swagger.json
@@ -5090,6 +5090,40 @@
       },
       "description": "Defines a series of if/else blocks. The first branch whose condition evaluates to true is the one to execute.\nIf no conditions were satisfied, the else_node or the error will execute."
     },
+    "coreK8sObjectMetadata": {
+      "type": "object",
+      "properties": {
+        "labels": {
+          "type": "object",
+          "additionalProperties": {
+            "type": "string"
+          },
+          "description": "Optional labels to add to the pod definition."
+        },
+        "annotations": {
+          "type": "object",
+          "additionalProperties": {
+            "type": "string"
+          },
+          "description": "Optional annotations to add to the pod definition."
+        }
+      },
+      "description": "Metadata for building a kubernetes object when a task is executed."
+    },
+    "coreK8sPod": {
+      "type": "object",
+      "properties": {
+        "metadata": {
+          "$ref": "#/definitions/coreK8sObjectMetadata",
+          "description": "Contains additional metadata for building a kubernetes pod."
+        },
+        "pod_spec": {
+          "$ref": "#/definitions/protobufStruct",
+          "title": "Defines the primary pod spec created when a task is executed.\nThis should be a JSON-marshalled pod spec, which can be defined in \n- go, using: https://github.com/kubernetes/api/blob/release-1.21/core/v1/types.go#L2936\n- python: using https://github.com/kubernetes-client/python/blob/release-19.0/kubernetes/client/models/v1_pod_spec.py"
+        }
+      },
+      "description": "Defines a pod spec and additional pod metadata that is created when a task is executed."
+    },
     "coreKeyValuePair": {
       "type": "object",
       "properties": {
@@ -5714,6 +5748,9 @@
         "container": {
           "$ref": "#/definitions/coreContainer"
         },
+        "k8s_pod": {
+          "$ref": "#/definitions/coreK8sPod"
+        },
         "task_type_version": {
           "type": "integer",
           "format": "int32",

diff --git a/flyteidl/gen/pb-go/flyteidl/service/flyteadmin/README.md b/flyteidl/gen/pb-go/flyteidl/service/flyteadmin/README.md
@@ -211,6 +211,8 @@ Class | Method | HTTP request | Description
  - [CoreIfBlock](docs/CoreIfBlock.md)
  - [CoreIfElseBlock](docs/CoreIfElseBlock.md)
  - [CoreIoStrategy](docs/CoreIoStrategy.md)
+ - [CoreK8sObjectMetadata](docs/CoreK8sObjectMetadata.md)
+ - [CoreK8sPod](docs/CoreK8sPod.md)
  - [CoreKeyValuePair](docs/CoreKeyValuePair.md)
  - [CoreLiteral](docs/CoreLiteral.md)
  - [CoreLiteralCollection](docs/CoreLiteralCollection.md)