create_job function was not printing the current status of the job. Modified the create_job function to call read_namespaced_job_status in order to get the current job status
In recent versions of K8S (>1.16?), when a `Watch.stream()` call uses a
resource_version which is too old the resulting 410 error is wrapped in JSON
and returned in a non-chunked 200 response. Using `resp.stream()` instead of
`resp.read_chunked()` automatically handles the response being either chunked or
non-chunked.
As a part of cleaning up inactive members (those with no activity within
the past 18 months) from OWNERS files, this commit moves mbohlool from
an approver to emeritus_approver.
To reproduce: Make sure to create a file outside of checked out python repo directory.
$ cat hello_k8s.py
import kubernetes
kubernetes.config.load_kube_config()
k8s = kubernetes.client.CoreV1Api()
print("Listing pods with their IPs:")
ret = k8s.list_pod_for_all_namespaces(watch=False)
for i in ret.items:
print("%s\t%s\t%s" % (i.status.pod_ip, i.metadata.namespace, i.metadata.name))
python hello_k8s.py
Traceback (most recent call last):
File "hello_k8s.py", line 1, in <module>
import kubernetes
File "<frozen zipimport>", line 259, in load_module
File "anaconda3/lib/python3.8/site-packages/kubernetes-17.0.0_snapshot-py3.8.egg/kubernetes/__init__.py", line 25, in <module>
ModuleNotFoundError: No module named 'kubernetes.leaderelection'
changed file naming style consistent with the existing go client code
Update example.py
Changed file and folder names
Rename LeaderElection.py to leaderelection.py
Rename threadingWithException.py to threadingwithexception.py
Rename ConfigMapLock.py to configmaplock.py
LeaderElection to leaderelection
Added boiler plate headers, updated variable and function names consistent with the guidelines, removed the ctypes dependency by using traces to kill threads, changed logic for leader now it gives up and doesn't re-join as a follower if it fails to update lease
added correct boiler plate year
Rename threadingWithTrace.py to threadingwithtrace.py
Update leaderelection.py
Update example.py
Changes based on review - logging, OnStoppedLeading is not killed abruptly, OnStartedLeading is not run in a separate thread, adding README
Update example.py
updated comments
set threads as daemon
Update README.md
Code made consistent with other clients.
Update example.py
Update leaderelection.py
Error & exception handling for the annotation, reduced indentation
Adding serializing functions for serializing & de-serializing locks, leader_election_record as a class
Adding a test
Adding boilerplate header
Rename leaderelectiontest.py to leaderelection_test.py
Updated boiler plates
handling imports for pytest
handling 'HTTP not found' compatibility with python 2 & 3, & handling relative imports
Update leaderelection.py
to check tests for tox
assertEquals -> assertEqual
Update leaderelection_test.py
making Threading compatible for Python 2
changing datetime.timestamp for backward compatibility with Python 2.7
Adding comments for test_Leader_election_with_renew_deadline & making
candidates run in parallel for test_leader_election
remove redundant daemon = True reassignment
common thread lock for MockResourceLock
