leaf_engine_flows.flow

Classes

DashboardFlow	A thin wrapper around LeafFlow to add dashboard specific functionality.
LeafFlow	A thin wrapper around Prefect's Flow class.

Module Contents

class leaf_engine_flows.flow.DashboardFlow(**kwargs)

Bases: LeafFlow

A thin wrapper around LeafFlow to add dashboard specific functionality.

class leaf_engine_flows.flow.LeafFlow(**kwargs)

Bases: prefect.Flow

A thin wrapper around Prefect’s Flow class.

disable_slack_notifications()

Disables slack notifications for all LeafTasks in the flow.

enable_read_cached_db_calls()

Enables reading cached DB calls for all DatabaseReadTasks in the flow.

enable_read_checkpoints()

Enables checkpoint reading for all LeafTasks in the flow.

enable_write_checkpoints()

Enables checkpoint writing for all LeafTasks in the flow.