Skip to content
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.

Sign up for GitHub

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

Jump to bottom

Add workQueues option to worker chart #212

Merged
merged 5 commits into from
Jul 26, 2023
Merged

Add workQueues option to worker chart #212

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
98f9c1a
add workqueue
jamiezieziula Jul 26, 2023
62dd14d
list instead of null
jamiezieziula Jul 26, 2023
e37decf
Update charts/prefect-worker/values.yaml
jamiezieziula Jul 26, 2023
1c2bfb2
helm docs
jamiezieziula Jul 26, 2023
9688553
no if
jamiezieziula Jul 26, 2023
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
3 changes: 2 additions & 1 deletion charts/prefect-worker/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,8 @@ Prefect Worker application bundle
| worker.config.limit | string | `nil` | Maximum number of flow runs to start simultaneously (default: unlimited) |
| worker.config.prefetchSeconds | int | `10` | when querying for runs, how many seconds in the future can they be scheduled |
| worker.config.queryInterval | int | `5` | how often the worker will query for runs |
| worker.config.workPool | string | `""` | name of prefect work pool the worker will poll |
| worker.config.workPool | string | `""` | the work pool the started worker should poll. |
| worker.config.workQueues | list | `[]` | one or more work queue names for the worker to pull from. if not provided, the worker will pull from all work queues in the work pool |
| worker.containerSecurityContext.allowPrivilegeEscalation | bool | `false` | set worker containers' security context allowPrivilegeEscalation |
| worker.containerSecurityContext.readOnlyRootFilesystem | bool | `true` | set worker containers' security context readOnlyRootFilesystem |
| worker.containerSecurityContext.runAsNonRoot | bool | `true` | set worker containers' security context runAsNonRoot |
Expand Down
6 changes: 6 additions & 0 deletions charts/prefect-worker/templates/deployment.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,12 @@ spec:
- kubernetes
- --pool
- {{ .Values.worker.config.workPool | quote }}
{{- if .Values.worker.config.workQueues }}
jamiezieziula marked this conversation as resolved.
Show resolved Hide resolved
{{- range .Values.worker.config.workQueues }}
- --work-queue
- {{ . }}
{{- end }}
{{- end }}
{{- if .Values.worker.config.limit }}
- --limit
- {{ .Values.worker.config.limit | quote }}
Expand Down
4 changes: 3 additions & 1 deletion charts/prefect-worker/values.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,10 @@ worker:

## general configuration of the worker
config:
# -- name of prefect work pool the worker will poll
# -- the work pool the started worker should poll.
jamiezieziula marked this conversation as resolved.
Show resolved Hide resolved
workPool: ""
# -- one or more work queue names for the worker to pull from. if not provided, the worker will pull from all work queues in the work pool
workQueues: []
# -- how often the worker will query for runs
queryInterval: 5
# -- when querying for runs, how many seconds in the future can they be scheduled
Expand Down