1
resposta

DAG para criar 2 pastas só está criando 1 pasta

Copiei o código exatamente assim:

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(2),
            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={{data_interval_end}}" '
        )

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

**

Executei na mesma ordem apresentada no vídeo, criei ativei o ambiente virtual, exclui e depois executei o novo DAG, mas só executou para 1 dia atrás e não 2 como deveria acontecer.

**

Insira aqui a descrição dessa imagem para ajudar na acessibilidade

Insira aqui a descrição dessa imagem para ajudar na acessibilidade

1 resposta

Olá, Luís, tudo bem?

Ao testar o código aqui funcionou normalmente, criando as duas pastas, como mostro na imagem abaixo:

captura de tela do meu primeiro dag no vscode. Está destacado em vermelho as duas pastas criadas

Luís, notei que há uma bolinha ao lado da aba de editor de código correspondente ao arquivo meu_primeiro_dag.py, indicando que há alguma alteração que não foi salva. Portanto, peço que certifique de ter salvo o arquivo, para isso basta selecionar os botões ctrl+s do teclado.

Caso o problema persista, fico à disposição.

Abraços e bons estudos!

Caso este post tenha lhe ajudado, por favor, marcar como solucionado ✓. Bons Estudos!