code: def finish_job(client, cleanup_job, job_completed_normally, client_outputs, pulsar_outputs):
      
      collection_failure_exceptions = []
      if job_completed_normally:
          output_collector = ClientOutputCollector(client)
          action_mapper = FileActionMapper(client)
          results_stager = ResultsCollector(output_collector, action_mapper, client_outputs, pulsar_outputs)
          collection_failure_exceptions = results_stager.collect()
      _clean(collection_failure_exceptions, cleanup_job, client)
      return collection_failure_exceptions
docs: Process for "un-staging" a complete Pulsar job.
  
      This function is responsible for downloading results from remote
      server and cleaning up Pulsar staging directory (if needed.)