leaf_engine_flows.run

Functions

run_flow(→ Tuple[str, str])

Registers and runs flow on Prefect Server.

Module Contents

leaf_engine_flows.run.run_flow(flow: prefect.Flow, flow_run_name: str, parameters: dict, project_name: str = 'core') → Tuple[str, str]

Registers and runs flow on Prefect Server.

Parameters:

  • flow (Flow) – The flow to run.

  • parameters (dict) – Flow parameters.

  • project_name (str, optional) – Defaults to “Core”.

  • register (bool, optional) – Whether to register the flow with the server. Defaults to True.

  • flow_run_name (str) –

Returns:

_description_

Return type:

Tuple[str, str]