flytekit.reference_task

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

A reference task is a pointer to a task 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_task(
    project="flytesnacks",
    domain="development",
    name="recipes.aaa.simple.join_strings",
    version="553018f39e519bdb2597b652639c30ce16b99c79",
)
def ref_t1(a: typing.List[str]) -> str:
    """
    The empty function acts as a convenient skeleton to make it intuitive to call/reference this task from workflows.
    The interface of the task must match that of the remote task. Otherwise, remote compilation of the workflow will
    fail.
    """
    ...
Parameters
  • project (str) –

  • domain (str) –

  • name (str) –

  • version (str) –

Return type

Callable[[Callable[[…], Any]], flytekit.core.task.ReferenceTask]