i2e_resource_deletion.py

from airflow.sdk import dag

from iqvia_nlp_provider.operators.i2e import I2EDeleteResourcesOperator


@dag(dag_id="example_dags.i2e_resource_deletion", schedule=None, catchup=False)
def i2e_resource_deletion():
    """
    DAG showing how to use the I2EDeleteResourcesOperator to delete all source data and indexes from a particular
    I2E folder.

    Requirements to use this DAG:
        - An I2E connection named `i2e_default`.
        - Some source data or indexes in the `my_folder` folder in I2E.
    """
    I2EDeleteResourcesOperator(
        i2e_conn_id="i2e_default", i2e_resource_types=["source_data", "index"], i2e_folder="my_folder"
    )


i2e_resource_deletion()