code: def mp_handler(use_subprocess, data, additional_parameters):
      if use_subprocess:
          process = multiprocessing.Pool(4)
      else:
          process = multiprocessing.pool.ThreadPool(4)
  
      process.map(mp_worker, zip(data, additional_parameters))
      process.close()
      print("DONE main !!!")
  
file_path: clearml/examples/distributed/subprocess_example.py
imports: import multiprocessing
  import os
  import subprocess
  import sys
  import time
  from argparse import ArgumentParser
  from random import randint
  from clearml import Task
label_desc: Use image node_id 2 for calling a global function with example usage: mp_handler(use_subprocess, data, additional_parameters) without return types