Os DAGs do Airflow são bem-sucedidos, mas as tarefas não estão em execução

Gowtham M

Estou tentando executar uma amostra do DAG do Airflow. O status do DAG é bem-sucedido, mas as tarefas não estão em execução. Alguém pode me ajudar a entender por quê?

Eu tentei o seguinte:

  • alterando a data de início para a data anterior
  • reiniciando o servidor web e o programador

insira a descrição da imagem aqui

Aqui está o meu código:

import datetime as dt

from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
print('test1')
def greet():
    print('Writing in file')
    print('testing the dag')
    with open('/Users/abc/Documents/airflow_workspace/greet.txt', 'a+', encoding='utf8') as f:
        now = dt.datetime.now()
        t = now.strftime("%Y-%m-%d %H:%M")
        f.write(str(t) + '\n')
    return 'Greeted'
def respond():
    return 'Greet Responded Again'

default_args = {
    'owner': 'airflow',
    'start_date': dt.datetime(2019, 3, 12, 10, 00, 00),
    'concurrency': 1,
    'retries': 0
}

with DAG('my_simple_dag',
         default_args=default_args,
         schedule_interval='*/10 * * * *',
         ) as dag:
    opr_hello = BashOperator(task_id='say_Hi',
                             bash_command='echo "Hi!!"')

    opr_greet = PythonOperator(task_id='greet',
                               python_callable=greet)
    opr_sleep = BashOperator(task_id='sleep_me',
                             bash_command='sleep 5')

    opr_respond = PythonOperator(task_id='respond',
                                 python_callable=respond)
print('test2')
opr_hello >> opr_greet >> opr_sleep >> opr_respond
Ofek Hod

Altere o nome dag_idde my_different_dagpara diferente; na verdade, ele criará um novo DAG.
Então, supondo que você configurou o fluxo de ar corretamente, ele deve funcionar agora.

Este artigo é coletado da Internet.

Se houver alguma infração, entre em [email protected] Delete.

editar em
0

deixe-me dizer algumas palavras

0comentários
loginDepois de participar da revisão

Artigos relacionados

Os DAGs do Airflow são bem-sucedidos, mas as tarefas não estão em execução

O Airflow 1.9.0 está na fila, mas as tarefas não estão em execução

As tarefas do Airflow DAG não estão em execução quando eu executo o DAG, apesar das tarefas funcionarem bem quando eu as testo

CodeBuild e CodeDeploy bem-sucedidos, mas não em execução no servidor para aplicativo maven javaweb

Execução de tarefas do Airflow em paralelo - nada é programado

Os arquivos bem-sucedidos do Xcode 7.2 não serão exibidos no organizador, mas serão exibidos na pasta de arquivos sobre a pasta de dados derivados

Os arquivos bem-sucedidos do Xcode 7.2 não serão exibidos no organizador, mas serão exibidos na pasta de arquivos sobre a pasta de dados derivados

Os testes de Karma são bem-sucedidos, mas o PhantomJS retorna "Um erro foi lançado em afterAll" SyntaxError: Token inesperado ','

O programador do Airflow falha ao coletar os DAGs programados, mas é executado quando acionado manualmente

Os envios de formulários do Netlify "bem-sucedidos" não aparecem no painel

O Gradle não tem conhecimento sobre a biblioteca de configuração automática personalizada - os testes falham no Gradle, mas são bem-sucedidos no IDE

Os contêineres do Docker estão em execução, mas não podem acessá-los

RegCreateKeyEx e RegOpenKeyEx são bem-sucedidos, mas RegSetValueEx falha ao definir o valor

Por que meus testes foram bem-sucedidos sem uma instância mongodb em execução?

Alarme do Android em execução, mas não quando os segundos são zero?

HangFire enfileiradas e-mails "bem-sucedidos", mas não enviados

Airflow "Esta conexão está fechada" em execução, mas não em teste

Os dags do Airflow não são reconhecidos ao executar o servidor da web como um daemon

A tarefa do Airflow não inicia, mas fica travada em "execução"

Como posso verificar se há DAGs em execução no Airflow (antes de reiniciar o Airflow)?

Alguns DAGs do Airflow estão gravando registros no S3, outros não

DAGs não clicáveis no servidor da web do Google Cloud Composer, mas funcionando bem em um fluxo de ar local

Os comandos do meu bot Discord não estão funcionando ... mas os eventos estão funcionando bem

Como evitar a execução de tarefas anteriormente bem-sucedidas no Airflow?

O comando ash shell não está em execução durante a construção da imagem, mas no contêiner funciona bem

java swing timer funciona bem em depuração, mas não em tempo de execução

Dags empacotados do Airflow (Zip) não escolhidos pelo programador

Finalizando o filtro em Scala em uma lista após um número de resultados bem-sucedidos

O código PHP não tem erros de execução, a operação de inserção foi bem-sucedida, mas os dados não estão presentes no

TOP lista

  1. 1

    R Shiny: use HTML em funções (como textInput, checkboxGroupInput)

  2. 2

    O Chromium e o Firefox exibem as cores de maneira diferente e não sei qual deles está fazendo certo

  3. 3

    Como assinar digitalmente um documento PDF com assinatura e texto visíveis usando Java

  4. 4

    R Folheto. Dados de pontos de grupo em células para resumir muitos pontos de dados

  5. 5

    Gerenciar recurso shake de Windows Aero com barra de título personalizado

  6. 6

    Como obter dados API adequados para o aplicativo angular?

  7. 7

    UITextView não está exibindo texto longo

  8. 8

    Por que meus intervalos de confiança de 95% da minha regressão multivariada estão sendo plotados como uma linha de loess?

  9. 9

    Acessando relatório de campanhas na AdMob usando a API do Adsense

  10. 10

    Usando o plug-in Platform.js do Google

  11. 11

    Como posso modificar esse algoritmo de linha de visada para aceitar raios que passam pelos cantos?

  12. 12

    Dependência circular de diálogo personalizado

  13. 13

    Coloque uma caixa de texto HTML em uma imagem em uma posição fixa para site para desktop e celular

  14. 14

    iOS: como adicionar sombra projetada e sombra de traço no UIView?

  15. 15

    Como usar a caixa de diálogo de seleção de nomes com VBA para enviar e-mail para mais de um destinatário?

  16. 16

    Tabela CSS: barra de rolagem para a primeira coluna e largura automática para a coluna restante

  17. 17

    How to create dynamic navigation menu select from database using Codeigniter?

  18. 18

    Converter valores de linha SQL em colunas

  19. 19

    ChartJS, várias linhas no rótulo do gráfico de barras

  20. 20

    用@StyleableRes注释的getStyledAttributes。禁止警告

  21. 21

    não é possível adicionar dependência para com.google.android.gms.tasks.OnSuccessListener

quentelabel

Arquivo