code: def _get_labels(extra_labels=None):
      if extra_labels is None:
          extra_labels = {}
      env_labels = (
          KUBERNETES_LABELS.split(",") if KUBERNETES_LABELS else []
      )
      env_labels = parse_kube_keyvalue_list(env_labels, False)
      labels = {**env_labels, **extra_labels}
      validate_kube_labels(labels)
      return labels
  
imports: import json
  import math
  import os
  import re
  import shlex
  import time
  from typing import Dict, List, Optional
  import uuid
  from uuid import uuid4
  from metaflow import current, util
  from metaflow.exception import MetaflowException
  from metaflow.metaflow_config import ARGO_EVENTS_EVENT, ARGO_EVENTS_EVENT_BUS, ARGO_EVENTS_EVENT_SOURCE, ARGO_EVENTS_SERVICE_ACCOUNT, ARGO_EVENTS_INTERNAL_WEBHOOK_URL, AWS_SECRETS_MANAGER_DEFAULT_REGION, ARGO_EVENTS_WEBHOOK_AUTH, AZURE_STORAGE_BLOB_SERVICE_ENDPOINT, CARD_AZUREROOT, CARD_GSROOT, CARD_S3ROOT, DATASTORE_SYSROOT_AZURE, DATASTORE_SYSROOT_GS, DATASTORE_SYSROOT_S3, DATATOOLS_S3ROOT, DEFAULT_AWS_CLIENT_PROVIDER, DEFAULT_METADATA, DEFAULT_SECRETS_BACKEND_TYPE, KUBERNETES_FETCH_EC2_METADATA, KUBERNETES_LABELS, KUBERNETES_SANDBOX_INIT_SCRIPT, S3_ENDPOINT_URL, SERVICE_HEADERS, SERVICE_INTERNAL_URL, S3_SERVER_SIDE_ENCRYPTION, OTEL_ENDPOINT
  from metaflow.metaflow_config_funcs import config_values
  from metaflow.mflog import BASH_SAVE_LOGS, bash_capture_logs, export_mflog_env_vars, get_log_tailer, tail_logs
  from .kubernetes_client import KubernetesClient
label_desc: Use image node_id 6 for calling the Kubernetes obj's underlying member method code with example usage: obj._get_labels(extra_labels) and returns: labels