code: def execute_call(
      in_queue, out_queue, handle, thread_local_data, event
  ):
      while not event.is_set():
          try:
              idx, in_data = in_queue.get(timeout=0.5)
          except queue.Empty:
              continue
          thread_local_data.micro_batch_idx = idx
          out_data = handle(in_data)
          out_queue.put((idx, out_data))
  
imports: import os
  import queue
  import threading
  import time
  from copy import copy
  from dataclasses import dataclass
  from typing import Dict
label_desc: Use image node_id 1 for calling a global function with example usage: execute_call(in_queue, out_queue, handle, thread_local_data, event) without return types