code: def mp_worker(arguments):
      print("sub process", os.getpid())
      data, extra_dict = arguments
      inputs, the_time = data
      Task.current_task().connect(extra_dict)
      print(" Process %s\tWaiting %s seconds" % (inputs, the_time))
      time.sleep(int(the_time))
      print(" Process %s\tDONE" % inputs)
  
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 1 for calling a global function with example usage: mp_worker(arguments) without return types