The custom extension for notifying(triggering) the Airflow DAG about the data to be uploaded to DataStore - View it on GitHub