Size: a a a

2021 April 03

SC

Stanislav Chernov in Airflow
источник

SC

Stanislav Chernov in Airflow
Ботов вообще нет у меня )
источник

С

Сюткин in Airflow
Stanislav Chernov
Ботов вообще нет у меня )
Так у нас тоже, то что они вступают, не даёт им право писать сообщения и они сами отваливаются

Сейчас убрал уведомление в чат о новом участнике, если это смущает
источник

SC

Stanislav Chernov in Airflow
👍
источник

AP

Anton Patsev in Airflow
А можно сделать капчу при входе?
источник

AP

Anton Patsev in Airflow
Сейчас вроде нет ее
источник

AP

Anton Patsev in Airflow
Уже все наверное боты умеют нажимать кнопку я не бот
источник

ME

Max Efremov in Airflow
Тест по airflow!
источник

➔m

➔◾ maria myznikova... in Airflow
Ага, угадай в какое время исполнится даг 😅
источник

С

Сюткин in Airflow
Anton Patsev
Уже все наверное боты умеют нажимать кнопку я не бот
Кхм, за последние 6 месяцев спама в данной группе вроде не было, от слова "совсем"

Если возникнет необходимость, добавим
источник

TB

Timur Berdy in Airflow
всем привет не беспокойтесь мы не боты, у нас прошла интересная конференция где отметили данный дружелюбный ресурс
источник
2021 April 04

VK

Vladimir K. in Airflow
Коллеги, всем привет. У кого-нибудь возникала подобная ошибка в таске?
[2021-04-04 09:05:37,166] {taskinstance.py:1150} ERROR - cannot import name 'make_kwargs_callable'
Traceback (most recent call last):
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/models/taskinstance.py", line 984, in _run_raw_task
   result = task_copy.execute(context=context)
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/sensors/base_sensor_operator.py", line 107, in execute
   while not self.poke(context):
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/providers/http/sensors/http.py", line 100, in poke
   from airflow.utils.operator_helpers import make_kwargs_callable
ImportError: cannot import name 'make_kwargs_callable'

Сама таска:
status_checker = HttpSensor(task_id='http_checker', http_conn_id=Variable.get('connectors_api'), endpoint=''
                           , request_params={}, response_check=lambda response: "httpbin" in response.text, dag=dag)

Импорт библиотеки:
from airflow.providers.http.sensors.http import HttpSensor

Версия airflow - 1.10.12
Версия pip - 20.2.3 (уточняю, т.к. по ссылке на данную библиотеку указано, что есть проблемы с pip 20.3)
источник

A

Alex in Airflow
Vladimir K.
Коллеги, всем привет. У кого-нибудь возникала подобная ошибка в таске?
[2021-04-04 09:05:37,166] {taskinstance.py:1150} ERROR - cannot import name 'make_kwargs_callable'
Traceback (most recent call last):
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/models/taskinstance.py", line 984, in _run_raw_task
   result = task_copy.execute(context=context)
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/sensors/base_sensor_operator.py", line 107, in execute
   while not self.poke(context):
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/providers/http/sensors/http.py", line 100, in poke
   from airflow.utils.operator_helpers import make_kwargs_callable
ImportError: cannot import name 'make_kwargs_callable'

Сама таска:
status_checker = HttpSensor(task_id='http_checker', http_conn_id=Variable.get('connectors_api'), endpoint=''
                           , request_params={}, response_check=lambda response: "httpbin" in response.text, dag=dag)

Импорт библиотеки:
from airflow.providers.http.sensors.http import HttpSensor

Версия airflow - 1.10.12
Версия pip - 20.2.3 (уточняю, т.к. по ссылке на данную библиотеку указано, что есть проблемы с pip 20.3)
это странно, но всё же — а есть такой файл в сборке? airflow/utils/operator_helpers.py

и есть ли в нем функция make_kwargs_callable?
источник

VK

Vladimir K. in Airflow
Alex
это странно, но всё же — а есть такой файл в сборке? airflow/utils/operator_helpers.py

и есть ли в нем функция make_kwargs_callable?
Отсутствует. В гите по этой версии тоже такой функции нет
Тут, конечно, предупреждают, что могут быть проблемы. Как я понимаю, придётся использовать deprecated модуль, раз не получается через airflow.providers
источник

AN

Anton Nakray in Airflow
/stat@combot
источник

C

Combot in Airflow
Total messages: 32384
источник

GB

Georgy Borodin in Airflow
Vladimir K.
Коллеги, всем привет. У кого-нибудь возникала подобная ошибка в таске?
[2021-04-04 09:05:37,166] {taskinstance.py:1150} ERROR - cannot import name 'make_kwargs_callable'
Traceback (most recent call last):
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/models/taskinstance.py", line 984, in _run_raw_task
   result = task_copy.execute(context=context)
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/sensors/base_sensor_operator.py", line 107, in execute
   while not self.poke(context):
 File "/opt/airflow/.venv/lib64/python3.6/site-packages/airflow/providers/http/sensors/http.py", line 100, in poke
   from airflow.utils.operator_helpers import make_kwargs_callable
ImportError: cannot import name 'make_kwargs_callable'

Сама таска:
status_checker = HttpSensor(task_id='http_checker', http_conn_id=Variable.get('connectors_api'), endpoint=''
                           , request_params={}, response_check=lambda response: "httpbin" in response.text, dag=dag)

Импорт библиотеки:
from airflow.providers.http.sensors.http import HttpSensor

Версия airflow - 1.10.12
Версия pip - 20.2.3 (уточняю, т.к. по ссылке на данную библиотеку указано, что есть проблемы с pip 20.3)
Может стоит посмотреть на backport providers?

https://airflow.apache.org/docs/apache-airflow/stable/backport-providers.html
источник
2021 April 05

VK

Vladimir K. in Airflow
Georgy Borodin
Может стоит посмотреть на backport providers?

https://airflow.apache.org/docs/apache-airflow/stable/backport-providers.html
С ним и есть проблемы.
from airflow.providers.http.sensors.http import HttpSensor - это пакет apache-airflow-backport-providers-http

https://pypi.org/project/apache-airflow-backport-providers-http/
источник

А

Андрей in Airflow
Всем привет. Кто-то сталкивался с отваливающимся шедулером в 2.0.1? Запускаю часовые таски за год, шедулер периодически отваливается. Надо рестартить. Когда часть периода отработана и тасков остается меньше, отваливаться перестает.
источник

А

Адиль in Airflow
Привет
Памяти хватает? Мож в него система стреляет
С какой ошибкой вылетает?
источник