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
FlyteRemote(config=Config.auto())
FlyteRemote(config=Config.auto(config_file=....))
FlyteRemote(config=Config(....))

# Or if you need to specify a custom cert chain
# (options and compression are also respected keyword arguments)
FlyteRemote(private_key=your_private_key_bytes, root_certificates=..., certificate_chain=...)

# fetch a workflow from the flyte backend
remote = FlyteRemote(...)
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.
`Options`	These are options that can be configured for a launchplan during registration or overridden during an execution.

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.