class_docstr: The parent class for TorchDistributor. This class shouldn't be instantiated directly.
class_docstr_tok: ["The","parent","class","for","TorchDistributor",".","This","class","should","n't","be","instantiated","directly","."]
docstr: Checks to see if the user requires encrpytion of data.
  If required, throw an exception since we don't support that.
  
  Raises
  ------
  RuntimeError
      Thrown when the user requires ssl encryption or when the user initializes
      the Distributor parent class.
docstr_tok: ["Checks","to","see","if","the","user","requires","encrpytion","of","data",".","If","required",",","throw","an","exception","since","we","do","n't","support","that",".","Raises","--","--","--","RuntimeError","Thrown","when","the","user","requires","ssl","encryption","or","when","the","user","initializes","the","Distributor","parent","class","."]
code: def _check_encryption(self) -> None:
      """Checks to see if the user requires encrpytion of data.
      If required, throw an exception since we don't support that.
  
      Raises
      ------
      RuntimeError
          Thrown when the user requires ssl encryption or when the user initializes
          the Distributor parent class.
      """
      if not hasattr(self, "ssl_conf"):
          raise RuntimeError(
              "Distributor doesn't have this functionality. Use TorchDistributor instead."
          )
      is_ssl_enabled = _get_conf_boolean(
          self.spark, "spark.ssl.enabled", "false"
      )
      ignore_ssl = _get_conf_boolean(self.spark, self.ssl_conf, "false")  # type: ignore
      if is_ssl_enabled:
          name = self.__class__.__name__
          if ignore_ssl:
              self.logger.warning(
                  textwrap.dedent(
                      f"""
                      This cluster has TLS encryption enabled;
                      however, {name} does not
                      support data encryption in transit.
                      The Spark configuration
                      '{self.ssl_conf}' has been set to
                      'true' to override this
                      configuration and use {name} anyway. Please
                      note this will cause model
                      parameters and possibly training data to
                      be sent between nodes unencrypted.
                      """,
                  )
              )
              return
          raise RuntimeError(
              textwrap.dedent(
                  f"""
                  This cluster has TLS encryption enabled;
                  however, {name} does not support
                  data encryption in transit. To override
                  this configuration and use {name}
                  anyway, you may set '{self.ssl_conf}'
                  to 'true' in the Spark configuration. Please note this
                  will cause model parameters and possibly training
                  data to be sent between nodes unencrypted.
                  """
              )
          )
  
imports: import json
  from contextlib import contextmanager
  import collections
  import logging
  import math
  import os
  import random
  import re
  import shutil
  import subprocess
  import sys
  import tempfile
  import textwrap
  import time
  from typing import Union, Callable, List, Dict, Optional, Any, Tuple, Generator, Iterator
  from pyspark import cloudpickle
  from pyspark.resource.information import ResourceInformation
  from pyspark.sql import DataFrame, SparkSession
  from pyspark.taskcontext import BarrierTaskContext
  from pyspark.ml.torch.log_communication import LogStreamingClient, LogStreamingServer
  from pyspark.ml.dl_util import FunctionPickler
label_desc: Use image node_id 5 for calling the Distributor obj's underlying member method code with example usage: obj._check_encryption() without return types