d03c17c40a2f3874c6b901d75763dcfc1492955c,workers/data_refinery_workers/processors/utils.py,,start_job,#Any#,11

Before Change

    if len(batches) == 0:
        logger.error("No batches found.", processor_job=job.id)
        return {"success": False}

    job_context["batches"] = batches
    return job_context

After Change

    logger.info("Starting processor Job.", processor_job=job.id)

    relations = ProcessorJobOriginalFileAssociation.objects.filter(processor_job=job)
    original_files = OriginalFile.objects.filter(id__in=relations.values("original_file_id"))

    if len(original_files) == 0:
        logger.error("No files found.", processor_job=job.id)
        job_context["success"] = False

Instances