code: def execute_async(q_in, q_out):
      while True:
          task = q_in.get()
  
          if task["type"] != "task":
              return
  
          record_id = task["record_id"]
          history_id = task["history_id"]
  
          executor = JobsExecutor()
          try:
              executor.execute_task_local(record_id, history_id)
          except (KeyboardInterrupt, SystemExit):
              q_out.put(True)
              raise
  
          except Exception:
              db.session.rollback()
  
          q_out.put(True)
  
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 for calling a global function with example usage: execute_async(q_in, q_out) without return types