code: def cp(src, dst):
      """Copy file from a persistent storage"""
      platform = CONFIG["platform"]
  
      parts_src = parse_file_path(src)
      parts_dst = parse_file_path(dst)
  
      if parts_src[0] and parts_dst[0]:
          raise ValueError(
              "Can't copy from persistent storage to persistent storage"
          )
  
      if parts_src[0]:
          volume = parts_src[0]
      elif parts_dst[0]:
          volume = parts_dst[0]
      else:
          raise ValueError("Must copy/to from a persistent volume")
  
      k8s_backend = get_backend(platform)
  
      job_spec = core.JobSpec(
          image="alpine:3.10",
          name="fiber-cp",
          command=["sleep", "60"],
          volumes={volume: {"mode": "rw", "bind": "/persistent"}},
      )
      job = k8s_backend.create_job(job_spec)
      pod_name = job.data.metadata.name
  
      print("launched pod: {}".format(pod_name))
      exitcode = os.system(
          "kubectl wait --for=condition=Ready pod/{}".format(pod_name)
      )
  
      """
      status = k8s_backend.get_job_status(job)
      while status == ProcessStatus.INITIAL:
          print("Waiting for pod {} to be up".format(pod_name))
          time.sleep(1)
  
      if status != ProcessStatus.STARTED:
          raise RuntimeError("Tempory pod failed: {}".format(pod_name))
      """
  
      if parts_src[0]:
          new_src = "{}:{}".format(pod_name, parts_src[1])
          new_dst = dst
      elif parts_dst[0]:
          new_src = src
          new_dst = "{}:{}".format(pod_name, parts_dst[1])
  
      cmd = "kubectl cp {} {}".format(new_src, new_dst)
      os.system(cmd)
  
imports: import os
  import json
  import subprocess
  from pathlib import Path
  import click
  import fiber
  import fiber.core
  from fiber.core import ProcessStatus
label_desc: Use image node_id 6 for calling a global function with example usage: cp(src, dst) without return types