2d1945f4a3c39b72f99e9af87b5eb0e3cf015d2e,workers/data_refinery_workers/processors/create_compendia.py,,_create_result_objects,#Any#,387

Before Change

    archive_computed_file.sync_to_s3(S3_BUCKET_NAME, key)

    job_context["result"] = result
    job_context["computed_files"] = [archive_computed_file]
    job_context["success"] = True

    log_state("end create result object", job_context["job"].id, result_start)

After Change

    if uploaded_to_s3:
        archive_computed_file.delete_local_file()
    else:
        raise utils.ProcessorJobError(
            "Failed to upload compendia to S3",
            success=False,
            computed_file_id=archive_computed_file.id,
        )

    job_context["result"] = result
    job_context["success"] = True

Instances