First version supporting direct stream calls per worker to the k8s apiserver to know the state of the launched jobs.
