Bitte geben Sie ein Beispiel für den örtlichen Airflow Local Executor an ⇐ Python

[Anonymous]

Ich habe Executor zum LocalExecuter in der Datei airflow.cfg gemacht. Aber wenn ich die DAG ausführe, wirft es immer noch Fehler, als ausführender Celeryexecutor (Parallelism = 64) Taskinstanz in die Warteschlange gestellt und fehlgeschlagen ist. P> und bitte geben Sie den Code von DAG an, wo wir Executor als LocalExecutor deklarieren können. Aber wenn ich die DAG ausführe, wirft es immer noch Fehler, als ausführender Celeryexecutor (Parallelism = 64) Taskinstanz in die Warteschlange gestellt und fehlgeschlagen ist. p> und bitte geben