default_args = { 'owner': 'svc-dpsd-airflow' 'depends_on_past': False 'email_on_failure': False #on_failure_callback': failure_callback 'retries': 0 } dag = DAG( 'mdp-dppe-mkteml-snowflake-ingestion-test' default_args=default_args start_date=datetime(2020 10 20 tzinfo=pendulum.timezone('US/Eastern')) schedule_interval = None max_active_runs=1 access_control={'dpsd_airflow_role':{'can_dag_read' 'can_dag_edit'}} description='DAG for Marketing and email datasets ingestion' catchup=False )

## Copy CSV data to S3 temp folder