-
Notifications
You must be signed in to change notification settings - Fork 16.4k
Closed
Description
Body
The hook uses _headers:
airflow/airflow/providers/http/hooks/http.py
Lines 340 to 341 in 9276310
| if headers: | |
| _headers.update(headers) |
but passes headers to the async function
airflow/airflow/providers/http/hooks/http.py
Lines 368 to 375 in 9276310
| response = await request_func( | |
| url, | |
| json=data if self.method in ("POST", "PATCH") else None, | |
| params=data if self.method == "GET" else None, | |
| headers=headers, | |
| auth=auth, | |
| **extra_options, | |
| ) |
The task:
headers=headers needs to be headers=_headers
airflow/airflow/providers/http/hooks/http.py
Line 372 in 9276310
| headers=headers, |
There was attempt to address it in #31010 but the PR become stale as no response from the author.
Committer
- I acknowledge that I am a maintainer/committer of the Apache Airflow project.