code: def run_warp_optical_flow(vid_item, dev_id=0):
      full_path, vid_path, vid_id = vid_item
      vid_name = vid_path.split(".")[0]
      out_full_path = osp.join(args.out_dir, vid_name)
      try:
          os.mkdir(out_full_path)
      except OSError:
          pass
  
      current = current_process()
      dev_id = (int(current._identity[0]) - 1) % args.num_gpu
      flow_x_path = "{}/flow_x".format(out_full_path)
      flow_y_path = "{}/flow_y".format(out_full_path)
  
      cmd = osp.join(
          args.df_path + "build/extract_warp_gpu"
      ) + " -f={} -x={} -y={} -b=20 -t=1 -d={} -s=1 -o={}".format(
          quote(full_path),
          quote(flow_x_path),
          quote(flow_y_path),
          dev_id,
          args.out_format,
      )
  
      os.system(cmd)
      print("warp on {} {} done".format(vid_id, vid_name))
      sys.stdout.flush()
      return True
  
imports: import argparse
  import sys
  import os
  import os.path
  import glob
  import fnmatch
  import random
  import zipfile
  from pipes import quote
  from multiprocessing import Pool, current_process
  import csv
label_desc: Use image node_id 3 for calling a global function with example usage: run_warp_optical_flow(vid_item, dev_id) and returns: True