Apache Воздушный поток: невозможно запустить планировщик - PullRequest
1 голос
/ 18 февраля 2020

Я новичок в Python и пытаюсь установить поток воздуха в моей маме c, следуя этому учебнику

Хотя эти две команды работают нормально:

$ airflow initdb

$ airflow webserver -p 8080

Команда планировщика (планировщик потока воздуха) выдает следующую ошибку:

[2020-02-18 13: 18: 09,012] {scheduler_job.py:1382} ОШИБКА - исключение при выполнении трассировки execute_helper (последний вызов был последним):

Файл "/ Users / mac / Рабочая область / airflow / airflow_venv / lib / python3 .8 / site-packages / airflow / jobs / scheduler_job.py ", строка 1380, в _execute self._execute_helper ()

Файл" / Users / mac / Рабочая область / airflow / airflow_venv / lib / python3 .8 / site-packages / airflow / jobs / scheduler_job.py ", строка 1413, в _execute_helper self.processor_agent.start ()

Файл" / Users / mac / Рабочая область / airflow / airflow_venv / lib / python3 .8 / site-packages / airflow / utils / dag_processing.py ", строка 554, в начале self._process.start ()

File" / Library / Framew orks / Python .framework / Versions / 3.8 / lib / python3 .8 / multiprocessing / process.py ", строка 121, в начале self._popen = self._Popen (self)

File" /Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/context.py ", строка 224, в _Popen return _default_context.get_context (). Process._Popen (process_obj)

Файл "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/context.py", строка 283, в _Popen return Popen (process_obj)

Файл "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/popen_spawn_posix.py", строка 32, в init super (). init (process_obj)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/popen_fork.py", строка 19, в init self._launch (process_obj)

File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/popen_spawn_posix.py ", строка 47, в _launch extension.dump (process_ob j, fp)

Файл "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/reduction.py", строка 60, в дампе ForkingPickler (файл , протокол) .dump (obj)

AttributeError: Невозможно выбрать локальный объект 'SchedulerJob._execute..processor_factory'

[2020-02-18 13: 18: 09,035] {помощники .py: 322} INFO - Отправка сигналов.SIGTERM в GPID Нет

Traceback (последний вызов был последним): Файл "/ Users / mac / Рабочая область / airflow / airflow_venv / bin / airflow", строка 37, в args.fun c (args) Файл "/Users/mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/airflow/utils/cli.py", строка 75, в возвращаемой оболочке f (* args, ** kwargs) Файл "/Users/mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/airflow/bin/cli.py", строка 1040, в планировщике job.run () Файл "/Users/mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/airflow/jobs/base_job.py", строка 221, в запуске файла self._execute () "/ Users /mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/a irflow / jobs / scheduler_job.py ", строка 1384, в файле _execute self.processor_agent.end ()" /Users/mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/airflow/utils/ dag_processing.py ", строка 707, в конце reap_process_group (self._process.pid, log = self.log) Файл" /Users/mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/airflow /utils/helpers.py ", строка 324, в файле reap_process_group signal_procs (sig)" /Users/mac/Workspace/airflow/airflow_venv/lib/python3.8/site-packages/airflow/utils/helpers.py " , строка 293, в signal_procs os.killpg (pgid, sig)

TypeError: требуется целое число (получил тип NoneType)

Кто-нибудь сталкивался с подобной проблемой?

1 Ответ

0 голосов
/ 10 марта 2020

Может быть, есть проблемы с совместимостью?

Используя Python 3.6.10 и airflow v1.10.4, я могу запустить поток воздуха. Может быть, вы могли бы попробовать другие версии?

...