Коллеги, всем привет. У кого-нибудь возникала подобная ошибка в таске?
[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)