airflow.example_dags.example_retry_policy

Example DAG demonstrating pluggable retry policies.

A retry policy evaluates the actual exception at failure time and decides whether to retry (with a custom delay), fail immediately, reschedule without using a retry, or fall through to the standard retry logic.

Attributes

`API_RETRY_POLICY`
`STANDARD_RETRY_POLICY`
`CHAINED_RETRY_POLICY`
`WAREHOUSE_RETRY_POLICY`

Exceptions

WarehouseBusyError

Raised by the task when the warehouse it submits queries to has no free slots.

Functions

call_external_api()

Module Contents

airflow.example_dags.example_retry_policy.API_RETRY_POLICY[source]

airflow.example_dags.example_retry_policy.call_external_api()[source]

airflow.example_dags.example_retry_policy.STANDARD_RETRY_POLICY[source]

airflow.example_dags.example_retry_policy.CHAINED_RETRY_POLICY[source]

exception airflow.example_dags.example_retry_policy.WarehouseBusyError[source]

Bases: Exception

Raised by the task when the warehouse it submits queries to has no free slots.

airflow.example_dags.example_retry_policy.WAREHOUSE_RETRY_POLICY[source]