Ao acessar a pagina WEB (Airflow), minha DAG apresentou erro de importação com o log descrito abaixo:
Broken DAG: [/home/lucassantos/Documents/airflowalura/dags/meuprimeirodag.py] Traceback (most recent call last): File "", line 913, in source_to_code File "", line 228, in callwith_frames_removed File "/home/lucassantos/Documents/airflowalura/dags/meuprimeirodag.py", line 17 bash_command = 'mkdir -p "/home/lucassantos/Documents/airflowalura/pasta"' ^ SyntaxError: invalid syntax
Porem, meu_primeiro_dag.py está exatamente igual o repassado em aula, segue o codigo abaixo:
from airflow.models import DAG from airflow.utils.dates import days_ago from airflow.operators.empty import EmptyOperator from airflow.operators.bash_operator import BashOperator
with DAG( 'meu_primeiro_dag', start_date=days_ago(1), schedule_interval='@daily' ) as dag:
tarefa_1 = EmptyOperator(task_id = 'tarefa_1')
tarefa_2 = EmptyOperator(task_id = 'tarefa_2')
tarefa_3 = EmptyOperator(task_id = 'tarefa_3')
tarefa_4 = BashOperator(
task_id = 'cria_pasta',
bash_command = 'mkdir -p "home/millenagena/Documents/airflowalura/pasta" '
)
tarefa_1 >> [tarefa_2, tarefa_3]
tarefa_3 >> tarefa_4
Como posso resolver o problema de import gerado.