JobStorage#

class nublado.controller.storage.kubernetes.deleter.JobStorage(api_client, reconnect_timeout, logger)#

Bases: KubernetesObjectDeleter[V1Job]

Storage layer for Job objects.

Parameters:
  • api_client (ApiClient) – Kubernetes API client.

  • reconnect_timeout (timedelta) – How long to wait before explictly restarting Kubernetes watches. This can prevent the connection from getting unexpectedly getting closed, resulting in 400 errors, or worse, events silently stopping.

  • logger (BoundLogger) – Logger to use.