-
Notifications
You must be signed in to change notification settings - Fork 277
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Document Tekton Pipeline support with pod integration #3898
base: main
Are you sure you want to change the base?
Changes from all commits
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,166 @@ | ||
--- | ||
title: "Run A Tekton Pipeline" | ||
date: 2024-01-03 | ||
weight: 7 | ||
description: > | ||
Integrate Kueue with Tekton Pipelines. | ||
--- | ||
|
||
This page shows how to leverage Kueue's scheduling and resource management capabilities when running [Tekton pipelines](https://tekton.dev/docs/). | ||
|
||
This guide is for [batch users](/docs/tasks#batch-user) that have a basic understanding of Kueue. For more information, see [Kueue's overview](/docs/overview). | ||
|
||
We demonstrate how to support scheduling Tekton Pipelines Tasks in Kueue based on the [Plain Pod](/docs/tasks/run_plain_pods) integration, where every Pod from a Pipeline is represented as a single independent Plain Pod. | ||
|
||
## Before you begin | ||
|
||
1. Learn how to [install Kueue with a custom manager configuration](/docs/installation/#install-a-custom-configured-released-version). | ||
2. Follow the steps in [Run Plain Pods](docs/tasks/run/plain_pods/#before-you-begin) to learn how to enable and configure the `v1/pod` integration. | ||
3. Check [Administrator cluster quotas](/docs/tasks/manage/administer_cluster_quotas/) for details on the initial Kueue step. | ||
|
||
The pod integration for TektonCD Pipelines could look like: | ||
|
||
```yaml | ||
apiVersion: config.kueue.x-k8s.io/v1beta1 | ||
kind: Configuration | ||
integrations: | ||
frameworks: | ||
- "pod" | ||
podOptions: | ||
# You can change namespaceSelector to define in which | ||
# namespaces kueue will manage the tektoncd pods. | ||
namespaceSelector: | ||
matchExpressions: | ||
- key: kubernetes.io/metadata.name | ||
operator: NotIn | ||
values: [ kube-system, kueue-system ] | ||
# Tekton pipelines uses the app.kubernetes.io/managed-by label to | ||
# keep track of pods it manages. We will use that as a hint for Kueue | ||
# to find Tekton pods. | ||
podSelector: | ||
matchExpressions: | ||
- key: app.kubernetes.io/managed-by | ||
operator: In | ||
values: [ "tekton-pipelines" ] | ||
``` | ||
|
||
2. Pods that belong to other API resources managed by Kueue are excluded from being queued by `pod` integration. | ||
For example, pods managed by `batch/v1.Job` won't be managed by `pod` integration. | ||
|
||
3. Check [Administer cluster quotas](/docs/tasks/administer_cluster_quotas) for details on the initial Kueue setup. | ||
Comment on lines
+21
to
+50
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Once we describe the basic Kueue setting the above, we can get rid of these configurations. |
||
|
||
4. Your cluster has tekton pipelines [installed](https://tekton.dev/docs/installation/pipelines/). | ||
|
||
|
||
## Tekton Background | ||
|
||
Tekton has the concept of [Pipelines](https://tekton.dev/vault/pipelines-v0.59.x-lts/pipelines/), [Tasks](https://tekton.dev/vault/pipelines-v0.59.x-lts/tasks/) and [PipelineRun](https://tekton.dev/vault/pipelines-v0.59.x-lts/pipelineruns/). | ||
|
||
A pipeline consists of tasks. Tasks and pipelines must be created before running a pipeline. | ||
|
||
A PipelineRun runs the pipeline. | ||
|
||
A TaskRun runs a single task. PipelineRuns will reuse TaskRuns to run each task in a pipeline. | ||
|
||
### Tekton Defintions | ||
|
||
As a simple example, we will define two tasks named sleep and hello: | ||
|
||
Tasks: | ||
|
||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Could you move Tekton specific manifests to https://github.com/kubernetes-sigs/kueue/tree/main/site/static/examples? |
||
```yaml | ||
apiVersion: tekton.dev/v1 | ||
kind: Task | ||
metadata: | ||
name: sleep | ||
spec: | ||
steps: | ||
- name: echo | ||
image: alpine | ||
script: | | ||
#!/bin/sh | ||
sleep 100 | ||
``` | ||
|
||
```yaml | ||
apiVersion: tekton.dev/v1 | ||
kind: Task | ||
metadata: | ||
name: hello | ||
spec: | ||
params: | ||
- name: username | ||
type: string | ||
steps: | ||
- name: hello | ||
image: ubuntu | ||
script: | | ||
#!/bin/bash | ||
echo "Hello $(params.username)!" | ||
``` | ||
|
||
A pipeline composes these tasks. | ||
|
||
```yaml | ||
apiVersion: tekton.dev/v1 | ||
kind: Pipeline | ||
metadata: | ||
name: kueue-test | ||
spec: | ||
params: | ||
- name: username | ||
type: string | ||
tasks: | ||
- name: sleep | ||
taskRef: | ||
name: sleep | ||
- name: hello | ||
runAfter: | ||
- sleep | ||
taskRef: | ||
name: hello | ||
params: | ||
- name: username | ||
value: $(params.username) | ||
``` | ||
|
||
## a. Targeting a single LocalQueue | ||
|
||
If you want every task to target a single [local queue](/docs/concepts/local_queue), | ||
it should be specified in the `metadata.label` section of the PipelineRun configuration. | ||
|
||
```yaml | ||
apiVersion: tekton.dev/v1 | ||
kind: PipelineRun | ||
metadata: | ||
generateName: kueue-test | ||
labels: | ||
kueue.x-k8s.io/queue-name: my-local-queue | ||
spec: | ||
pipelineRef: | ||
name: kueue-test | ||
params: | ||
- name: username | ||
value: "Tekton" | ||
``` | ||
|
||
This will inject the kueue label on every pod of the pipeline. Kueue will gate the pods once you are over the quota limits. | ||
|
||
## c. How it works | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I think that we should remove this section since this page does not indicate the concept and mechanism. We just describe the user's documentation step by step. |
||
|
||
Tekton pipelines manages its own pods, and only creates those pods once task nodes are | ||
ready to execute. When configured, Kueue attaches an admission webhook that monitors for | ||
pods created by Tekton pipelines. When it finds a newly created pod, it will add an | ||
entry to the `spec.schedulingGates` parameter of the pod, preventing the Kubernetes scheduler | ||
from assigning a node to the pod. It also creates a corresponding `Workload` resource to | ||
track the resource requirements. Once the Workload meets all admission criteria, | ||
Kueue will remove the scheduling gate and allow the pod to proceed. | ||
|
||
Once the pod is scheduled and runs successfully, Tekton will register the task complete and continue with it's processing. | ||
|
||
## d. Limitations | ||
|
||
- Kueue will only manage pods created by Tekton. | ||
- Each pod in a Workflow will create a new Workload resource and must wait for admission by Kueue. | ||
- There is no way to ensure that a Workflow will complete before it is started. If one step of a multi-step Workflow does not have | ||
available quota, Tekton pipelines will run all previous steps and then wait for quota to become available. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I do not think that we should configure this Pod selector since this selector prevents the management of Pod except for the Tekton Pipeline Pods.