mysterious-painter-66441
10/30/2025, 3:37 PMmysterious-painter-66441
10/30/2025, 3:40 PMmysterious-painter-66441
10/30/2025, 3:46 PMversion = "7951bdb5-09a0-469f-b9ca-fb1749136365" # We have registered workflow using this verison
PROJECT_NAME = "test_project"
PROJECT_DOMAIN = "development"
remote = FlyteRemote(
config=Config.auto(config_file=str(Path(__file__).parent.parent / "flytekit.config")),
default_project=PROJECT_NAME,
default_domain=PROJECT_DOMAIN,
)
wf = remote.fetch_workflow(
name="workflows.test_wf", version=version, domain=PROJECT_DOMAIN, project=PROJECT_NAME
)
lp_name = "test_lp"
wf_lp = LaunchPlan.create(
name=lp_name,
workflow=wf,
default_inputs={
"name": "John",
},
schedule=CronSchedule(schedule="0 0 1 * *"),
)
# Register the launch plan
remote.register_launch_plan(wf_lp, version=version)echoing-account-76888
10/31/2025, 3:07 AMreference_workflow
@reference_workflow(project="project", domain="domain", name="name", version="version")
def ref_wf1(p1: str, p2: str) -> None:
...
lp = LaunchPlan.create("reference-wf-12345", ref_wf1, fixed_inputs={"p1": "p1-value", "p2": "p2-value"})