Running a Launchplan

Flytectl

This is multi-steps process where we create an execution spec file, update the spec file and then create the execution. More details can be found here.

Generate an execution spec file

flytectl get launchplan -p flytesnacks -d development myapp.workflows.example.my_wf  --execFile exec_spec.yaml

Update the input spec file for arguments to the workflow

....
inputs:
    name: "adam"
....

Create execution using the exec spec file

flytectl create execution -p flytesnacks -d development --execFile exec_spec.yaml

Monitor the execution by providing the execution id from create command

flytectl get execution -p flytesnacks -d development <execid>

FlyteRemote

A launch plan can be launched via FlyteRemote programmatically.

from flytekit.remote import FlyteRemote
from flytekit.configuration import Config
from flytekit import LaunchPlan

# FlyteRemote object is the main entrypoint to API
remote = FlyteRemote(
    config=Config.for_endpoint(endpoint="flyte.example.net"),
    default_project="flytesnacks",
    default_domain="development",
)

# Fetch launch plan
flyte_lp = remote.fetch_launch_plan(
    name="workflows.example.wf", version="v1", project="flytesnacks", domain="development"
)

# Execute
execution = remote.execute(
    flyte_launch_plan, inputs={"mean": 1}, execution_name="lp_execution", wait=True
)