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.