code: def __init__(self, args):
      super().__init__(
          _start_run,
          _is_queue,
          name="Dask scheduler",
          init_cb=_init_client,
          can_start_cb=_can_start_run,
          wait_for_running_cb=_wait_for_running,
          sync_state_cb=_sync_state_for_staged,
          cleanup_cb=_cleanup,
          max_startable_runs=1,
          poll_interval=args.poll_interval,
          run_once=args.run_once,
          wait_for_running=args.wait_for_running,
          gpus=args.gpus,
      )
      self.args = args
      self.futures = []
      self._logged_missing_resoures = set()
  
imports: import argparse
  import logging
  import time
  from guild import _api
  from guild import util
  from .None import gen_queue
label_desc: Use image node_id 1 to create a new State object from inherited base classes: gen_queue with example: obj = State(args)