flytekit.reference_workflow

flytekit.reference_workflow(project, domain, name, version)[source]

A reference workflow is a pointer to a workflow that already exists on your Flyte installation. This object will not initiate a network call to Admin, which is why the user is asked to provide the expected interface. If at registration time the interface provided causes an issue with compilation, an error will be returned.

Example:

@reference_workflow(project="proj", domain="development", name="wf_name", version="abc")
def ref_wf1(a: int) -> typing.Tuple[str, str]:
    ...
Parameters
  • project (str) –

  • domain (str) –

  • name (str) –

  • version (str) –

Return type

Callable[[Callable[[…], Any]], flytekit.core.workflow.ReferenceWorkflow]