code: def executor_submitter(executor, workers, *args, **kwargs):
      futures = []
      for worker in range(workers):
          future = executor.submit(*args, **kwargs)
          futures.append(future)
  
      results = [future.result() for future in futures]
      results = list(itertools.chain.from_iterable(results))
  
      return results
  
file_path: cortex/test/utils/throughput_test.py
imports: import os
  import sys
  import click
  import concurrent.futures
  import requests
  import imageio
  import json
  import time
  import itertools
  import cv2
  import numpy
  from validator_collection import checkers
label_desc: Use image node_id 3 for calling a global function with example usage: executor_submitter(executor, workers) and returns: results