c0833c03181a2a9a2ce50bf43281ba698f61887c,workers/data_refinery_workers/processors/smasher.py,,_smash_all,#Any#,303

Before Change

                         processor_job_id=job_context["job_id"],
                         num_input_files=job_context["num_input_files"])
        job_context["dataset"].success = False
        job_context["job"].failure_reason = "Failure reason: " + str(e)
        job_context["dataset"].failure_reason = "Failure reason: " + str(e)
        job_context["dataset"].save()
        // Delay failing this pipeline until the failure notify has been sent
        job_context["job"].success = False

After Change

    try:
        shutil.make_archive(final_zip_base, "zip", job_context["output_dir"])
    except:
        raise utils.ProcessorJobError("Smash Error while generating zip file", success=False)

    job_context["output_file"] = final_zip_base + ".zip"

    job_context["dataset"].success = True

Instances