MCPcopy
hub / github.com/kubernetes-sigs/kueue

github.com/kubernetes-sigs/kueue @v0.18.2 sqlite

repository ↗ · DeepWiki ↗ · release v0.18.2 ↗
10,638 symbols 51,751 edges 1,232 files 4,867 documented · 46%
README

Kueue

GoReport Widget Latest Release Ask DeepWiki

kueue logo

Kueue is a set of APIs and controller for job queueing. It is a job-level manager that decides when a job should be admitted to start (as in pods can be created) and when it should stop (as in active pods should be deleted).

Read the overview and watch the Kueue-related talks & presentations to learn more.

Features overview

Production Readiness status

Based on community feedback, we continue to simplify and evolve the API to address new use cases.

Installation

Requires Kubernetes 1.29 or newer.

To install the latest release of Kueue in your cluster, run the following command:

kubectl apply --server-side -f https://github.com/kubernetes-sigs/kueue/releases/download/v0.18.2/manifests.yaml

The controller runs in the kueue-system namespace.

Read the installation guide to learn more.

Usage

A minimal configuration can be set by running the examples:

kubectl apply -f examples/admin/single-clusterqueue-setup.yaml

Then you can run a job with:

kubectl create -f examples/jobs/sample-job.yaml

Learn more about:

Roadmap

High-level overview of the main priorities for 2026: - Improve user experience for MultiKueue - multi-cluster Job dispatching, in particular: * Support Elastic RayJob #8712 * Workload-Level Admission Constraints and Preference-Aware MultiKueue Dispatching #8729 * Prevent starting preemptions in multiple worker clusters #8303 * Support long running services #8526 * Log retrieval from worker clusters #3526 - Improve user experience for Topology Aware Scheduling, in particular: * Support for ResourceTransformations #8860 * Support for Elastic Workloads #8160 * Evict workloads which are running on nodes which become tainted #8838 - Integration with the k8s native Workload-Aware Scheduler (WAS) and Topology-Aware Scheduling #8871 - Support for Concurrent Workload Admission #8691 - Support for running hero workloads #8826 - Consider preemption cost when finding preemption candidates #7990 - Progress towards Beta for the integration with Dynamic Resource Allocation (DRA) #8243

Long-term aspirational goals: - Partial preemption of serving workloads #3762 - Integration with workflow frameworks #74 - Budget support #28 - Flavor assignment strategies, e.g. minimizing cost vs minimizing borrowing #312 - Cooperative preemption support for workloads that implement checkpointing #477 - Delayed preemption for two-stage admission #3758 - Support Structured Parameters (DRA) in Kueue #2941 - Graduate the API to v1 #3476

Community, discussion, contribution, and support

Learn how to engage with the Kubernetes community on the community page and the contributor's guide.

You can reach the maintainers of this project at:

Graphic assets

Code of conduct

Participation in the Kubernetes community is governed by the Kubernetes Code of Conduct.

Extension points exported contracts — how you extend this code

JobWithPriorityClass (Interface)
JobWithPriorityClass is an optional interface that should be implemented by generic jobs when a custom priority class is [12 …
pkg/controller/jobframework/interface.go
Wrapper (Interface)
Wrapper is used to wrap a function that will run in a goroutine. [19 implementers]
pkg/util/routine/wrapper.go
WorkloadPriorityClassesGetter (Interface)
WorkloadPriorityClassesGetter has a method to return a WorkloadPriorityClassInterface. A group's client should implement [6 …
client-go/clientset/versioned/typed/kueue/v1beta1/workloadpriorityclass.go
GenericInformer (Interface)
GenericInformer is type of SharedIndexInformer which will locate and delegate to other sharedInformers based on type [27 …
client-go/informers/externalversions/generic.go
WorkloadPriorityClassLister (Interface)
WorkloadPriorityClassLister helps list WorkloadPriorityClasses. All objects returned here must be treated as read-only. [3 …
client-go/listers/kueue/v1beta1/workloadpriorityclass.go
StatusChecker (Interface)
StatusChecker checks status of clusterQueue. [2 implementers]
pkg/cache/queue/status_checker.go
Client (Interface)
(no doc) [3 implementers]
cmd/kueueviz/backend/handlers/gvr.go
Option (FuncType)
Option configures the reconciler.
pkg/scheduler/scheduler.go

Core symbols most depended-on inside this repo

Obj
called by 17806
pkg/util/testing/wrappers.go
Queue
called by 2902
pkg/util/testingjobs/pod/wrappers.go
Request
called by 2770
pkg/util/testingjobs/pod/wrappers.go
Get
called by 2718
client-go/listers/kueue/v1beta2/cohort.go
PodSets
called by 2507
pkg/controller/jobframework/interface.go
Label
called by 2462
pkg/util/testing/wrappers.go
MustCreate
called by 2194
test/util/util.go
Resource
called by 1677
pkg/util/testing/v1beta1/wrappers.go

Shape

Method 5,177
Function 3,988
Struct 1,063
Interface 237
TypeAlias 124
FuncType 48
Class 1

Languages

Go99%
TypeScript1%
Python1%

Modules by API surface

apis/kueue/v1beta1/zz_generated.conversion.go281 symbols
pkg/util/testing/v1beta2/wrappers.go253 symbols
apis/kueue/v1beta2/zz_generated.deepcopy.go198 symbols
apis/kueue/v1beta1/zz_generated.deepcopy.go180 symbols
pkg/workload/workload.go147 symbols
test/util/util.go132 symbols
pkg/util/testing/wrappers.go112 symbols
pkg/cache/scheduler/tas_flavor_snapshot.go85 symbols
apis/config/v1beta1/zz_generated.conversion.go84 symbols
pkg/metrics/metrics.go77 symbols
pkg/cache/scheduler/cache.go77 symbols
pkg/cache/queue/manager.go73 symbols

Dependencies from manifests, versioned

4d63.com/gocheckcompilerdirectivesv1.3.0 · 1×
4d63.com/gochecknoglobalsv0.2.2 · 1×
al.essio.dev/pkg/shellescapev1.5.1 · 1×
cel.dev/exprv0.25.1 · 1×
cloud.google.com/gov0.123.0 · 1×
cloud.google.com/go/auth/oauth2adaptv0.2.8 · 1×
cloud.google.com/go/compute/metadatav0.9.0 · 1×
cloud.google.com/go/monitoringv1.24.3 · 1×
cloud.google.com/go/storagev1.57.2 · 1×
codeberg.org/chavacava/garifv0.2.0 · 1×

For agents

$ claude mcp add kueue \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact