Airflow SimpleHttpOperator не отправляет xcom

У меня есть следующий SimpleHttpOperator внутри моего дага:

extracting_user = SimpleHttpOperator(
        task_id='extracting_user',
        http_conn_id='user_api',
        endpoint='api/', # Some Api already configured and checked
        method = "GET",
        response_filter=lambda response: json.loads(response.text),
        log_response=True,
        do_xcom_push=True,
    )

за которым следует PythonOperator:

processing_user = PythonOperator(
        task_id='processing_user',
        python_callable=_processing_user
    )

Функция:

def _processing_user(ti):
    users = ti.xcom_pull(task_ids=['extracting_user'])
    if not len(users) or 'results' not in users[0]:
        raise ValueError(f'User is empty')

    **More function code**

Когда я выполняю airflow tasks test myDag extracting_user 2022-03-02, а затем airflow tasks test myDag processing_user 2022-03-02, я получаю ошибку значения с переменной пользователей, равной пустому массиву.

Я протестировал задачу extracting_user в одиночку, и она получает нужные данные из API. Я уже запросил sqlite xcom, и это пустая таблица.

Я использую воздушный поток 2.3.0