Masalah Apakah ada cara di Airflow untuk membuat alur kerja sehingga jumlah tugas B. * tidak diketahui hingga tugas A selesai? Saya telah melihat subdag tetapi sepertinya itu hanya dapat bekerja dengan serangkaian tugas statis yang harus ditentukan saat pembuatan Dag. Akankah pemicu belati...
setelah instalasi baru menggunakan pip install apache-airflow, setiap upaya untuk menjalankan aliran udara diakhiri dengan kesalahan impor python: Traceback (most recent call last): File "/Users/\*/env/bin/airflow", line 26, in <module> from airflow.bin.cli import CLIFactory File...
Instalasi dilakukan dengan benar. db dimulai dengan benar dan mencoba memulai server web menunjukkan kesalahan berikut. Saya menginstal ulang semuanya tetapi masih tidak berfungsi. Saya akan menghargai jika ada yang membantu saya. Output konsol: $:~/airflow# airflow webserver -p 8080...
Tutup. Pertanyaan ini tidak dapat direproduksi atau disebabkan oleh kesalahan ketik . Saat ini tidak menerima jawaban. Ingin meningkatkan pertanyaan ini? Perbarui pertanyaan sehingga sesuai topik untuk Stack Overflow. Ditutup 3 bulan lalu . Saya...
Saya menggunakan https://github.com/helm/charts/tree/master/stable/airflow helm chart dan membangun puckle/docker-airflowgambar v1.10.8 dengan kubernet terinstal di atasnya dan menggunakan gambar itu di grafik helm, Tapi saya tetap mendapatkan File "/usr/local/bin/airflow", line 37, in...
Saya mencoba memindahkan file s3 dari bucket "non-deleting" (artinya saya tidak bisa menghapus file) ke GCS menggunakan aliran udara. Saya tidak dapat dijamin bahwa file baru akan ada di sana setiap hari, tetapi saya harus memeriksa file baru setiap hari. masalah saya adalah penciptaan dinamis...
Saya memiliki scenerio seperti di bawah ini: Trigger a Task 1dan Task 2hanya ketika data baru avialable untuk mereka dalam tabel sumber (Athena). Pemicu untuk Task1 dan Task2 harus terjadi ketika partisi data baru dalam sehari. Pemicu Task 3hanya pada penyelesaian Task 1danTask 2 Hanya memicu...