punchbowl.prefect#

Functions#

`completion_debugger`(→ None)	Run on task completion during debug mode.
`failure_hook`(→ None)	Run if a punch_task fails.
`punch_task`(→ prefect.Task)	Prefect task that does PUNCH special things.
`punch_flow`(→ prefect.Flow)	Prefect flow that does PUNCH special things.

Module Contents#

punchbowl.prefect.completion_debugger(task: prefect.Task, task_run: prefect.client.schemas.objects.TaskRun, state: prefect.states.State) → None[source]#: Run on task completion during debug mode.

punchbowl.prefect.failure_hook(task: prefect.Task, task_run: prefect.client.schemas.objects.TaskRun, state: prefect.states.State) → None[source]#: Run if a punch_task fails.

punchbowl.prefect.punch_task(*args: Any, **kwargs: Any) → prefect.Task[source]#: Prefect task that does PUNCH special things.

punchbowl.prefect.punch_flow(*args: Any, **kwargs: Any) → prefect.Flow[source]#: Prefect flow that does PUNCH special things.