leaf_engine_flows.notify

Functions

_get_flow_success_message(→ Optional[str])

_get_task_failure_message(→ Optional[str])

notify_slack(→ prefect.engine.state.State)

Custom Slack notification method. Can be used as state_handler for both

Module Contents

leaf_engine_flows.notify._get_flow_success_message(flow: prefect.Flow, old_state: prefect.engine.state.State, new_state: prefect.engine.state.State) → str | None
Parameters:

  • flow (prefect.Flow) –

  • old_state (prefect.engine.state.State) –

  • new_state (prefect.engine.state.State) –

Return type:

Optional[str]

leaf_engine_flows.notify._get_task_failure_message(task: prefect.Task, old_state: prefect.engine.state.State, new_state: prefect.engine.state.State) → str | None
Parameters:

  • task (prefect.Task) –

  • old_state (prefect.engine.state.State) –

  • new_state (prefect.engine.state.State) –

Return type:

Optional[str]

leaf_engine_flows.notify.notify_slack(tracked_obj: prefect.Flow | prefect.Task, old_state: prefect.engine.state.State, new_state: prefect.engine.state.State) → prefect.engine.state.State

Custom Slack notification method. Can be used as state_handler for both flows and tasks.

Parameters:

  • tracked_obj (Union[Flow, Task]) – Flow or Task to notify about. Passed in by Prefect.

  • old_state (State) – State object passed in by Prefect.

  • new_state (State) – State object passed in by Prefect.

Returns:

State object used by Prefect.

Return type:

State