code: def __init__(self, config=None):
      self.config = config
  
      self.q_in = queue.Queue()
      self.q_out = queue.Queue()
      self.work_thread = threading.Thread(
          target=execute_async, args=(self.q_in, self.q_out)
      )
      self.work_thread.start()
  
file_path: mindsdb/mindsdb/interfaces/jobs/scheduler.py
imports: import datetime
  import queue
  import random
  import threading
  import time
  from mindsdb.interfaces.jobs.jobs_controller import JobsExecutor
  from mindsdb.interfaces.storage import db
  from mindsdb.utilities import log
  from mindsdb.utilities.config import Config
label_desc: Use image node_id 1 to create a new Scheduler object  with example: obj = Scheduler(config)