def __init__(self, kube_client: client.CoreV1Api=None, in_cluster: bool=True, cluster_context: Optional[str]=None, extract_xcom: bool=False):
    '\n        Creates the launcher.\n\n        :param kube_client: kubernetes client\n        :param in_cluster: whether we are in cluster\n        :param cluster_context: context of the cluster\n        :param extract_xcom: whether we should extract xcom\n        '
    super().__init__()
    self._client = (kube_client or get_kube_client(in_cluster=in_cluster, cluster_context=cluster_context))
    self._watch = watch.Watch()
    self.extract_xcom = extract_xcom
Creates the launcher.

:param kube_client: kubernetes client
:param in_cluster: whether we are in cluster
:param cluster_context: context of the cluster
:param extract_xcom: whether we should extract xcom
def __init__(self, kube_client: client.CoreV1Api=None, in_cluster: bool=True, cluster_context: Optional[str]=None, extract_xcom: bool=False):
    '\n        Creates the launcher.\n\n        :param kube_client: kubernetes client\n        :param in_cluster: whether we are in cluster\n        :param cluster_context: context of the cluster\n        :param extract_xcom: whether we should extract xcom\n        '
    super().__init__()
    self._client = (kube_client or get_kube_client(in_cluster=in_cluster, cluster_context=cluster_context))
    self._watch = watch.Watch()
    self.extract_xcom = extract_xcom