Remote Access

This module provides utilities for performing operations on tasks, workflows, launchplans, and executions, for example, the following code fetches and executes a workflow:

# create a remote object from flyte config and environment variables
remote = FlyteRemote.from_config()

# fetch a workflow from the flyte backend
flyte_workflow = remote.fetch_workflow(name="my_workflow", version="v1")

# execute the workflow, wait=True will return the execution object after it's completed
workflow_execution = remote.execute(flyte_workflow, inputs={"a": 1, "b": 10}, wait=True)

# inspect the execution's outputs
print(workflow_execution.outputs)

Entrypoint

FlyteRemote

Main entrypoint for programmatically accessing a Flyte remote backend.

Entities

FlyteTask

A class encapsulating a remote Flyte task.

FlyteWorkflow

A class encapsulating a remote Flyte workflow.

FlyteLaunchPlan

A class encapsulating a remote Flyte launch plan.

Entity Components

FlyteNode

A class encapsulating a remote Flyte node.

FlyteTaskNode

A class encapsulating a task that a Flyte node needs to execute.

FlyteWorkflowNode

A class encapsulating a workflow that a Flyte node needs to execute.

Execution Objects

FlyteWorkflowExecution

A class encapsulating a workflow execution being run on a Flyte remote backend.

FlyteTaskExecution

A class encapsulating a task execution being run on a Flyte remote backend.

FlyteNodeExecution

A class encapsulating a node execution being run on a Flyte remote backend.