DAGS с часовым поясом для Apache Airflow - PullRequest
Новая
       24

DAGS с часовым поясом для Apache Airflow

0 голосов
/ 01 октября 2019

В документации по Apache Airflow говорится, что легко узнать часовой пояс DAG. Вот приведенный пример: 

import pendulum

local_tz = pendulum.timezone("Europe/Amsterdam")

default_args=dict(
    start_date=datetime(2016, 1, 1, tzinfo=local_tz),
    owner='Airflow'
)

Это кажется довольно простым, и я попытался подражать этому, чтобы мой DAG мог работать по тихоокеанскому времени, поэтому я изменил «Европа / Амстердам» на «США / Тихий океан»,На моем сервере Ubuntu, где я установил Airflow, я также выполнил «pip3 install pendulum», как указано в документации по маятнику.

По какой-то причине, когда я запускаю «airflow resetdb» после обновления моего кода, я получаю этоошибка:

ImportError: невозможно импортировать имя 'Pendulum'.

Кто-нибудь знает, почему это происходит или как это исправить? В качестве альтернативы, есть ли другой способ, который работает для часовых поясов в Apache Airflow? Я осмотрелся и не смог его достать. Благодарю.

...