aiohttp: Response payload is not completed #235
Description
After about 3 minutes I got an error: aiohttp.client_exceptions.ClientPayloadError: Response payload is not completed
Run:
async def get_events(v1, field_selector: str):
w = watch.Watch()
async with w.stream(
v1.list_event_for_all_namespaces,
field_selector=field_selector,
) as stream:
return stream
async def show_events(events):
async for event in events:
evt, obj = event["type"], event["object"]
print(
"-" * 40,
f"\nMETHOD: {evt}\n"
f"KIND: {obj.kind}\n"
f"NAME: {obj.metadata.name}\n"
f"NAMESPACE: {obj.metadata.namespace}\n"
f"MESSAGE: {obj.message}\n",
)
async def watch_events() -> None:
async with ApiClient() as api:
v1 = client.CoreV1Api(api)
res_events = await asyncio.gather(
*[
get_events(v1, f"involvedObject.kind={name}")
for name in ["Cluster", "Node"]
]
)
await asyncio.gather(*[show_events(event) for event in res_events])
python: 3.7.2 and 3.9.12
kubernetes_asyncio: 18.20.0 and 24.2.2