Kubernetes API молча зависает, вызывая утечки потоков ⇐ Python

[Anonymous]

У меня есть скрипт мониторинга работоспособности, который проверяет журналы контейнера каждые 30 секунд. Скрипт основан на клиентском API Kubernetes, код довольно прост, как показано ниже

Код: Выделить всё

from kubernetes import client, config, utils, watch

api_instance = client.CoreV1Api(self.k8s_client)
w = watch.Watch()
for e in w.stream(api_instance.read_namespaced_pod_log, name=pod_id,
namespace=namespace, tail_lines=lines, container=container):
blah...

Я запускаю это внутри потока и продолжаю проверять thread.is_alive(), чтобы убедиться, что мой поток работает.
Недавно я начал регистрировать номер количества потоков, активно работающих в моем приложении, что значительно превышает ожидаемое.
Оказывается, API зависает, thread.is_alive() имеет значение false, и я создам новый поток.
Однако старая тема активен, работает и зависает.
Известна ли это проблема Kubernetes? Есть ли другой способ справиться с этой вечно висящей темой?

Подробнее здесь: https://stackoverflow.com/questions/791 ... read-leaks