Clean up temporary tables once either the DAG or upstream tasks are done
Install the Astro SDK provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Clean up temporary tables once either the DAG or upstream tasks are done. The cleanup operator allows for two possible scenarios: Either a user wants to clean up a specific set of tables during the DAG run, or the user wants to ensure that all temporary tables are deleted once the DAG run is finished. The idea here is to ensure that even if a user doesn't have access to a "temp" schema, that astro does not leave hanging tables once execution is done.