def end_job_input(job_path, opts = {})
      url     = job_url(job_path, '/live/in/end')
      headers = gen_headers(opts)

      attempt(opts[:attempts]) do
        result = @client.post(url, nil, headers)
        raise unless result.is_a? HTTP::Message

        return true, result.headers if result.status == 202
        raise_error(result)
      end
    end
def end_job_input(job_path, opts = {})
      url     = job_url(job_path, '/live/in/end')
      headers = gen_headers(opts)

      attempt(opts[:attempts]) do
        result = @client.post(url, nil, headers)
        raise unless result.is_a? HTTP::Message

        return true, result.headers if result.status == 202
        raise_error(result)
      end
    end
Inform Manta that no more objects will be added for processing by a job,
 and that the job should finish all phases and terminate.

 The job_path must start with /<user>/jobs/<job UUID> and point at an actual
 running job.

 Returns true, along with received HTTP headers.

 If there was an unrecoverable error, throws an exception. On connection or
 corruption errors, more attempts will be made; the number of attempts can
 be altered by passing in :attempts.