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#
Main entrypoint for programmatically accessing a Flyte remote backend. |
|
These are options that can be configured for a launchplan during registration or overridden during an execution. |
Entities#
A class encapsulating a remote Flyte task. |
|
A class encapsulating a remote Flyte workflow. |
|
A class encapsulating a remote Flyte launch plan. |
Entity Components#
A class encapsulating a remote Flyte node. |
|
A class encapsulating a task that a Flyte node needs to execute. |
|
A class encapsulating a workflow that a Flyte node needs to execute. |
Execution Objects#
A class encapsulating a workflow execution being run on a Flyte remote backend. |
|
A class encapsulating a task execution being run on a Flyte remote backend. |
|
A class encapsulating a node execution being run on a Flyte remote backend. |