c0833c03181a2a9a2ce50bf43281ba698f61887c,workers/data_refinery_workers/processors/smasher.py,,_upload,#Any#,354

Before Change

                pass

    except Exception as e:
        logger.exception("Failed to upload smash result file.", file=job_context["output_file"])
        job_context["job"].success = False
        job_context["job"].failure_reason = "Failure reason: " + str(e)
        // Delay failing this pipeline until the failure notify has been sent
        // job_context["success"] = False

After Change

                              output_filename,
                              ExtraArgs={"ACL":"public-read"})
    except Exception as e:
        raise utils.ProcessorJobError("Failed to upload smash result file.",
                                      success=False,
                                      file=job_context["output_file"])

    result_url = ("https://s3.amazonaws.com/" + RESULTS_BUCKET + "/" +
                  output_filename)

Instances