Entrar Ainda não tem acesso?
Solucionado (ver solução)
Solucionado
(ver solução)
2
respostas

[Dúvida] Dag não aparece na interface do airflow

Referente ao curso Apache Airflow: orquestrando seu primeiro pipeline de dados, no capítulo DAGs, Tasks e Operators e atividade Executando nosso primeiro DAG

por Caíque Santos Goulart
| 41.3k xp | 7 posts
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/ununtu/Documents/airflow_alura/pasta"'
    )


    tarefa_1 >> [tarefa_2, tarefa_3]
    tarefa_3>> tarefa_4

Meu dag não está aparecendo na interface, o código parece estar correto, e as pastas também.

2 respostas
solução!
por Monalisa Meyrelle de Sousa Silva
| 1708.1k xp | 3890 posts
Alura Scuba Team Monitoria Fórum Ops

Olá, Caíque, tudo bem?

Para identificar esse erro, peço que faça algumas verificações:

Verifique se o arquivo do DAG está no diretório correto, identifique se arquivo ele está localizado no diretório especificado do Airflow.

Além disso, notei que você está tentando criar uma pasta com o comando mkdir -p "/home/ununtu/Documents/airflow_alura/pasta". Seria ununt mesmo ou ubuntu? Peço que faça essa verificação e caso seja ubuntu, peço que corrija o código para: mkdir -p "/home/ubuntu/Documents/airflow_alura/pasta".

Outro ponto importante é que o Airflow pode levar algum tempo para atualizar a interface gráfica. Então, se você acabou de criar ou modificar o DAG, pode ser necessário esperar um pouco e atualizar a página.

Se o problema persistir, fico à disposição.

Abraços e até mais!

Caso este post tenha lhe ajudado, por favor, marcar como solucionado ✓. Bons Estudos!
por Caíque Santos Goulart
| 41.3k xp | 7 posts

Olá Monalisa!

Fiz todas as verificações mas estava tudo correto, por algum motivo quando criei a VM o nome ficou como "ununtu" haha

Porém hoje o dag apareceu na interface, imagino que era por causa da demora para atualizar que vc mencionou, só achei estranho demorar tanto.

Obrigado!