DataHub Assertion Circuit Breaker Operator.

View on GitHub

Last Updated: Dec. 2, 2022

Access Instructions

Install the DataHub provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


urnRequiredThe DataHub dataset unique identifier. (templated)
datahub_rest_conn_idThe REST datahub connection id to communicate with DataHub which is set as Airflow connection.
check_last_assertion_timeIf set it checks assertions after the last operation was set on the dataset. By default it is True.
time_deltaIf verify_after_last_update is False it checks for assertion within the time delta.


DataHub Assertion Circuit Breaker Operator.

Was this page helpful?