Tag: apache-airflow
Status von Luftstrom Aufgabe innerhalb der dag
4 Antworten
Ich brauche den status der Aufgabe, wie wenn es in Betrieb ist oder upforretry oder nicht innerhalb der gleichen dag. So habe ich versucht, bekomme es mit dem code unten, aber ich habe keine Ausgabe... Auto =
airflow pass-parameter von cli
2 Antworten
Gibt es eine Möglichkeit, übergeben Sie einen parameter: airflow trigger_dag dag_name {param} ? Ich habe ein script, das überwacht ein Verzeichnis für Dateien, wenn eine Datei bekommt, verschiebt in das Zielverzeichnis an, ich will zum auslösen der
Wie zu stoppen/töten Luftstrom scheduler gestartet im daemon-Modus
2 Antworten
Ich und neue Luftstrom, und versehentlich gestartet Luftstrom scheduler daemon-mode. Nun, ich möchte töten, der Planer und ggf. neu starten. Ich habe versucht zu tun, sudo kill -9 <list of pids> pkill <name> nichts ist passiert. Wenn
Apache Luftstrom DAG nicht importieren lokale Modul
2 Antworten
Scheine ich nicht zu verstehen, wie Sie import-Module in apache Luftstrom DAG-definition-Datei. Ich würde mir wünschen, dies tun zu können, erstellen Sie eine Bibliothek, die macht das deklarieren von Aufgaben mit ähnlichen Einstellungen weniger ausführlich, zum Beispiel.
Luftstrom ist fehlgeschlagen slack-Nachricht
3 Antworten
Wie kann ich konfigurieren Sie den Luftstrom so, dass alle Fehler in der DAG wird (sofort) zu einer slack-Nachricht? In diesem moment Schaffe ich es durch die Schaffung eines slack_failed_task: slack_failed_task = SlackAPIPostOperator( task_id='slack_failed', channel="#datalabs", trigger_rule='one_failed', token="...",
Wie richte ich den Luftstrom, der E-Mail Konfiguration zum versenden einer E-Mail auf Fehler?
1 Antworten
Ich versuche, mich ein Luftstrom Aufgabe absichtlich scheitern und Fehler aus, indem in einer Bash-Zeile ( thisshouldnotrun ), das funktioniert nicht. Luftstrom ist die Ausgabe folgende: [2017-06-15 17:44:17,869] {bash_operator.py:94} INFO - /tmp/airflowtmpLFTMX7/run_bashm2MEsS: line 7: thisshouldnotrun: command not
Luftstrom Aufgaben stecken an in der "Warteschleife" - status und wird nie laufen
4 Antworten
Ich bin mit der Airflow-v1.8.1 und führen Sie alle Komponenten (Arbeiter -, web -, Blumen -, scheduler) auf kubernetes & Andockfenster. Ich verwende Sellerie Testamentsvollstrecker mit Redis und meine Aufgaben sind wie folgt aussieht: (start) -> (do_work_for_product1)