class_docstr: A Remote Dask Worker controlled by SSH
  
  Parameters
  ----------
  scheduler: str
      The address of the scheduler
  address: str
      The hostname where we should run this worker
  worker_class: str
      The python class to use to create the worker.
  connect_options: dict
      kwargs to be passed to asyncssh connections
  remote_python: str
      Path to Python on remote node to run this worker.
  kwargs: dict
      These will be passed through the dask worker CLI to the
      dask.distributed.Worker class
code: def __init__(  # type: ignore[no-untyped-def]
      self,
      scheduler: str,
      address: str,
      connect_options: dict,
      kwargs: dict,
      worker_module="deprecated",
      worker_class="distributed.Nanny",
      remote_python=None,
      loop=None,
      name=None,
  ):
      super().__init__()
  
      if worker_module != "deprecated":
          raise ValueError(
              "worker_module has been deprecated in favor of worker_class. "
              "Please specify a Python class rather than a CLI module."
          )
  
      self.address = address
      self.scheduler = scheduler
      self.worker_class = worker_class
      self.connect_options = connect_options
      self.kwargs = copy.copy(kwargs)
      self.name = name
      self.remote_python = remote_python
      if (
          kwargs.get("nprocs") is not None
          and kwargs.get("n_workers") is not None
      ):
          raise ValueError(
              "Both nprocs and n_workers were specified. Use n_workers only."
          )
      elif kwargs.get("nprocs") is not None:
          warnings.warn(
              "The nprocs argument will be removed in a future release. It has been "
              "renamed to n_workers.",
              FutureWarning,
          )
          self.n_workers = self.kwargs.pop("nprocs", 1)
      else:
          self.n_workers = self.kwargs.pop("n_workers", 1)
  
imports: from __future__ import annotations
  import copy
  import logging
  import sys
  import warnings
  import weakref
  from json import dumps
  from typing import Any
  import dask
  import dask.config
  from distributed.deploy.spec import ProcessInterface, SpecCluster
label_desc: Use image node_id 1 to create a new Worker object from inherited base classes: Process with example: obj = Worker(scheduler, address, connect_options, kwargs, worker_module, worker_class, remote_python, loop, name)