Utils

Kubernetes Utils

kubernetes_manager.utils.coalesce_dicts(target=<class 'dict'>, source=<class 'dict'>)

kubernetes_manager.utils.find_namespaced_pods(namespace, job_name, api_client)

find pod by namespace and job name

Args:

namespace (str) - job_name (str) - api_client (CoreV1Api) -

Returns:

str - Name of the pod if found

kubernetes_manager.utils.generate_kubeconfig(context, cluster, user, default_name='k8s-job-runner')

Format helper for generating individual cluster kubeconfigs

Args:

context (dict) - cluster (dict) - user (dict) -

Returns:

dict -

kubernetes_manager.utils.get_command_output(cmd)

retrieve command output for a given command provided

kubernetes_manager.utils.get_dict_hash(data)

kubernetes_manager.utils.run_command(cmd, log_method=<bound method Logger.info of <Logger kubernetes_manager.utils (WARNING)>>)

Subprocess wrapper for capturing output of processes to logs

kubernetes_manager.utils.split_kubeconfig(kubeconfig)

Helper method to split a kubeconfig into separate, per-cluster configurations

Args:

kubeconfig (dict or str) -

Returns:

list(dict)