code: def process_task(
      working_directory,
      output_directory,
      bucket_file_path,
      tqdm_func,
      global_tqdm,
  ):
      command = f"zstd {bucket_file_path}"
      logger.info(command)
      subprocess.call(command, shell=True)
  
      compressed_file = bucket_file_path + ".zst"
      if output_directory:
          shutil.move(compressed_file, output_directory)
  
      os.remove(bucket_file_path)
      global_tqdm.update()
  
file_path: lm-evaluation-harness/scripts/clean_training_data/compress_and_package.py
imports: import glob
  import argparse
  import os
  import subprocess
  import shutil
  from tqdm import tqdm
  from tqdm_multiprocess import TqdmMultiProcessPool
  import logging
  from tqdm_multiprocess.logger import setup_logger_tqdm
label_desc: Use image node_id 1 for calling a global function with example usage: process_task(working_directory, output_directory, bucket_file_path, tqdm_func, global_tqdm) without return types