Pytania otagowane jako airflow-scheduler

1
Program planujący przepływ powietrza nie uruchamia się z executorem kubernetes
Korzystam z https://github.com/helm/charts/tree/master/stable/airflow wykresu steru i buduję puckle/docker-airflowobraz v1.10.8 z zainstalowanymi na nim kubernetes i używam tego obrazu z wykresu sterów, ale ciągle otrzymuję File "/usr/local/bin/airflow", line 37, in <module> args.func(args) File "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 1140, in initdb db.initdb(settings.RBAC) File "/usr/local/lib/python3.7/site-packages/airflow/utils/db.py", line 332, in initdb dagbag = models.DagBag() File "/usr/local/lib/python3.7/site-packages/airflow/models/dagbag.py", line …

1
Jak uruchomić zadanie przepływu powietrza tylko wtedy, gdy nowa partycja / dane są dostępne w tabeli AWS athena przy użyciu DAG w pythonie?
Mam scenerię jak poniżej: Naciśnij Task 1iTask 2 tylko wtedy, gdy nowe dane są dla nich dostępne w tabeli źródłowej (Athena). Wyzwalacz dla Zadania 1 i Zadania 2 powinien się zdarzyć, gdy nowa parowanie danych nastąpi w ciągu jednego dnia. Wyzwalacz Task 3 tylko po zakończeniu Task 1iTask 2 Uruchom …
Korzystając z naszej strony potwierdzasz, że przeczytałeś(-aś) i rozumiesz nasze zasady używania plików cookie i zasady ochrony prywatności.
Licensed under cc by-sa 3.0 with attribution required.