def run_pod_async(self, pod: V1Pod, **kwargs):
    'Runs POD asynchronously'
    pod_mutation_hook(pod)
    sanitized_pod = self._client.api_client.sanitize_for_serialization(pod)
    json_pod = json.dumps(sanitized_pod, indent=2)
    self.log.debug('Pod Creation Request: \n%s', json_pod)
    try:
        resp = self._client.create_namespaced_pod(body=sanitized_pod, namespace=pod.metadata.namespace, **kwargs)
        self.log.debug('Pod Creation Response: %s', resp)
    except Exception as e:
        self.log.exception('Exception when attempting to create Namespaced Pod: %s', json_pod)
        raise e
    return resp
Runs POD asynchronously
def run_pod_async(self, pod: V1Pod, **kwargs):
    
    pod_mutation_hook(pod)
    sanitized_pod = self._client.api_client.sanitize_for_serialization(pod)
    json_pod = json.dumps(sanitized_pod, indent=2)
    self.log.debug('Pod Creation Request: \n%s', json_pod)
    try:
        resp = self._client.create_namespaced_pod(body=sanitized_pod, namespace=pod.metadata.namespace, **kwargs)
        self.log.debug('Pod Creation Response: %s', resp)
    except Exception as e:
        self.log.exception('Exception when attempting to create Namespaced Pod: %s', json_pod)
        raise e
    return resp