in app/source/dragen/src/dragen_qs.py [0:0]
def upload_job_outputs(self):
if not self.output_s3_url:
printf('Error: Output S3 location not specified!')
return
# Generate the command to upload the results
s3_valid, s3_bucket, s3_key = get_s3_bucket_key(self.output_s3_url)
if not s3_valid or not s3_key or not s3_bucket:
printf('Error: could not get S3 bucket and key info from specified URL %s' % self.output_s3_url)
sys.exit(1)
ul_cmd = '{bin} --mode upload --bucket {bucket} --key {key} --path {file} -s'.format(
bin=self.D_HAUL_UTIL,
bucket=s3_bucket,
key=s3_key,
file=self.output_dir.rstrip('/'))
exit_code = exec_cmd(ul_cmd)
if exit_code:
printf('Error: Failure uploading outputs. Exiting with code %d' % exit_code)
sys.exit(exit_code)
return