<filename>airflow_elt_scripts/dags/my_first_dag.py
#importando as bibliotecas que vamos usar nesse exemplo
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.bash_operator import BashOperator

#Definindo alguns argumentos básicos
default_args = {
	'owner': 'howard',
	'depends_on_past': False,
	'start_date': datetime(2020, 3, 30),
	'retries': 0
	}

'''Nomeando a DAG e definindo quando ela vai ser executada (você pode
usar argumentos de Crontab também caso queira que a DAG execute por
exemplo todos os dias as 8 da manhã'''

with DAG(
	'my-first-dag',
	schedule_interval=timedelta(minutes=1),
	catchup=False,
	default_args=default_args
	) as dag:
#Definindo as tarefas que a DAG vai executar, nesse caso a execução de dois programas Python, chamando sua execução por comandos bash
    t1 = BashOperator(task_id='first_etl',
		      bash_command="""
		      cd $AIRFLOW_HOME/dags/etl_scripts/
		      python3 my_first_etl_script.py
		      """)

    t2 = BashOperator(task_id='second_etl',
		      bash_command="""
		      cd $AIRFLOW/dags/etl_scripts/
		      python3 my_second_etl_script.py
		      """)
#Definindo o padrão de execução, nesse caso executamos t1 e depois t2
    t1 >> t2



<filename>airflow_elt_scripts/dags/my_first_dag.py
#importando as bibliotecas que vamos usar nesse exemplo
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.bash_operator import BashOperator

#Definindo alguns argumentos básicos
default_args = {
	'owner': 'howard',
	'depends_on_past': False,
	'start_date': datetime(2020, 3, 30),
	'retries': 0
	}

'''Nomeando a DAG e definindo quando ela vai ser executada (você pode
usar argumentos de Crontab também caso queira que a DAG execute por
exemplo todos os dias as 8 da manhã'''

with DAG(
	'my-first-dag',
	schedule_interval=timedelta(minutes=1),
	catchup=False,
	default_args=default_args
	) as dag:
#Definindo as tarefas que a DAG vai executar, nesse caso a execução de dois programas Python, chamando sua execução por comandos bash
    t1 = BashOperator(task_id='first_etl',
		      bash_command="""
		      cd $AIRFLOW_HOME/dags/etl_scripts/
		      python3 my_first_etl_script.py
		      """)

    t2 = BashOperator(task_id='second_etl',
		      bash_command="""
		      cd $AIRFLOW/dags/etl_scripts/
		      python3 my_second_etl_script.py
		      """)
#Definindo o padrão de execução, nesse caso executamos t1 e depois t2
    t1 >> t2



#importando as bibliotecas que vamos usar nesse exemplo #Definindo alguns argumentos básicos Nomeando a DAG e definindo quando ela vai ser executada (você pode usar argumentos de Crontab também caso queira que a DAG execute por exemplo todos os dias as 8 da manhã #Definindo as tarefas que a DAG vai executar, nesse caso a execução de dois programas Python, chamando sua execução por comandos bash cd $AIRFLOW_HOME/dags/etl_scripts/ 		      python3 my_first_etl_script.py cd $AIRFLOW/dags/etl_scripts/ 		      python3 my_second_etl_script.py #Definindo o padrão de execução, nesse caso executamos t1 e depois t2