Воздушный поток TimeDeltaSensor терпит неудачу с неподдерживаемым типом операнда

Выражение int(float(s)), упомянутое другими, является лучшим, если вы хотите усечь значение. Если вы хотите округлить, используя int(round(float(s)), если круглый алгоритм соответствует тому, что вы хотите (см. round documentation ), в противном случае вы должны использовать Decimal и один, если его алгоритмы округления.

0
задан jamiet 13 July 2018 в 09:15
поделиться

1 ответ

Заглянув в исходный код, который вы связали, есть одна строка, которая кажется мне интересной в этом случае:

target_dttm = dag.following_schedule(context['execution_date'])

Это означает: если у вас нет настройки правильного расписания DAG, этот компонент будет попробуйте добавить его дельта времени к None.

Я не уверен, что код в вопросе - всего лишь пример или все это. Мое предложение: Добавить график DAG с другим, кроме None.

0
ответ дан tobi6 17 August 2018 в 13:17
поделиться