2
respostas

DAG Import Errors (1)

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.

2 respostas

Problema resolvido.

Encerrei a maquina virtual e a reativei ela ... desta forma, ao acessar novamente o DAG no web service estava disponivel e sem erros.

Olá, Lucas, tudo bem?

Que bom que conseguiu resolver do import e obrigada por compartilhar a forma que solucionou, isso pode ajudar outros alunos .

Continue com dedicação aos estudos para assim consolidar os conhecimentos adquiridos.

Caso surja quaisquer dúvidas, é só compartilhar no fórum.

Grande abraço e bons estudos!