Skip to content

Fix HttpAsyncHook headers #32390

@eladkal

Description

@eladkal

Body

The hook uses _headers:

if headers:
_headers.update(headers)

but passes headers to the async function

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

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.

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions