0.15.0
Union plugin
Directory
Classes
| Class | Description |
|---|---|
flyteplugins.union.factory.Factory |
A set of builds. |
flyteplugins.union.factory.TimeRange |
A trailing window, relative to the consumer’s own time value, ending at that value. |
flyteplugins.union.io.ActionRef |
Provenance: the action (one task execution within a run) that produced a particular Volume version, plus the output slot it was returned as. |
flyteplugins.union.io.BlockVolume |
A writable Volume whose content is one ext4 filesystem image. |
flyteplugins.union.io.ROBlockVolume |
An immutable version of a BlockVolume – what its commit and finalize return, and what a downstream task receives. |
flyteplugins.union.io.ROVolume |
Immutable, versioned volume — PRD §Core Concepts. |
flyteplugins.union.io.RWVolume |
Mutable working copy — PRD §Core Concepts. |
flyteplugins.union.io.Volume |
A persistent volume identified by its metadata index. |
flyteplugins.union.remote.ApiKey |
Represents a Union API Key (OAuth Application). |
flyteplugins.union.remote.Assignment |
Represents role/policy assignments for an identity. |
flyteplugins.union.remote.Cluster |
Represents a Union cluster. |
flyteplugins.union.remote.ClusterConfig |
The tracked ConfigMaps of a single cluster. |
flyteplugins.union.remote.ClusterPool |
Represents a Union cluster pool — the configuration shared by its member clusters. |
flyteplugins.union.remote.Environment |
One environment version with its full spec, scaling and per-cluster status snapshots. |
flyteplugins.union.remote.EnvironmentVersion |
One environment version as returned by the list call: its summary and per-cluster summaries. |
flyteplugins.union.remote.Member |
Represents a Union organization member (user or application). |
flyteplugins.union.remote.MetricResult |
The result of querying one metric. |
flyteplugins.union.remote.MetricSeries |
One time series of a metric result, e.g. one container or one GPU device. |
flyteplugins.union.remote.Metrics |
Pod metrics of a task’s action attempt or of an app, as shown in the Union UI. |
flyteplugins.union.remote.Policy |
Represents a Union RBAC Policy. |
flyteplugins.union.remote.Queue |
Represents a Union scheduling queue. |
flyteplugins.union.remote.Role |
Represents a Union RBAC Role. |
flyteplugins.union.remote.SSHDebug |
Resolved SSH-into-task connect info for a running debug action. |
flyteplugins.union.remote.SystemLogs |
Logs of the Union system components running on a cluster’s dataplane. |
flyteplugins.union.remote.User |
Represents a Union user. |
flyteplugins.union.remote.VolumeExplore |
A resolved Volume plus the IO to inspect and walk its lineage. |
flyteplugins.union.remote.VolumeResolveError |
No (or ambiguous) Volume-typed value could be resolved on an action. |
Functions
| Function | Description |
|---|---|
flyteplugins.union.debug() |
Launch a task, or relaunch an existing run, with ssh-into-task debug enabled. |
flyteplugins.union.fork() |
Fork run run_name, replaying it with new code and/or inputs. |
flyteplugins.union.with_debugcontext() |
Like flyte.with_runcontext, but preconfigured for ssh-into-task debug. |
flyteplugins.union.with_forkcontext() |
Like flyte.with_runcontext, but the returned runner can also fork(run_name, ...). |
flyteplugins.union.factory.build() |
Name the artifact (or artifacts) one task call makes. |
flyteplugins.union.factory.materialize() |
Start a run of <factory>.materialize and return the flyte.remote.Run. |
flyteplugins.union.factory.on() |
Materialize when a source gets a new version, or on a schedule. |
flyteplugins.union.factory.partition() |
Pass the instance’s value of dim to a task parameter. |
flyteplugins.union.factory.serve() |
Name the app a factory ends in. |
flyteplugins.union.factory.source() |
An artifact made outside this factory. |
flyteplugins.union.io.allow_volumes() |
Enable Volume mounts in a task pod with zero privileges. |
flyteplugins.union.io.with_high_throughput_volume_deps() |
Prepare base for high-throughput (Redis-backed) Volumes. |
flyteplugins.union.io.with_local_flyteplugins() |
Package the locally checked-out flyteplugins-union (built to a wheel) and an optional local juicefs binary into base — for iterating on an unreleased plugin build against a real cluster. |
flyteplugins.union.utils.with_local_flyteplugins_union() |
Layer the locally-built flyteplugins-union wheel onto img. |
Packages
| Package | Description |
|---|---|
flyteplugins.union |
Union SDK - Proprietary extensions for Flyte. |
flyteplugins.union.factory |
Factories: a declared graph of partitioned artifacts the platform can materialize on demand. |
flyteplugins.union.io |
Persistent, mountable :class:Volume type for the Flyte SDK v2. |
flyteplugins.union.remote |
Union remote control plane objects. |
flyteplugins.union.utils |
Public utilities for flyteplugins.union. |