code: def pyspark_parallel(sc, tasks, task_duration):
      nums = sc.parallelize([task_duration for i in range(tasks)])
      nums.map(sleep_worker).collect()
  
imports: import time
  import fiber
  import multiprocessing
  import logging
  import subprocess
  import argparse
  from pprint import pprint
label_desc: Use image node_id 8 for calling a global function with example usage: pyspark_parallel(sc, tasks, task_duration) without return types