class GcpJobStatusService implements JobStatusService {

  @Override
  public void updateJobStatus(String jobId, IngestJobStatus status) {
    log.debug("Update the injection job status. JobId: {}, status: {}", jobId, status);
    ingestJobRepository.updateFields(jobId, ImmutableMap.of("status", status.name()));
    log.debug("Updated the injection job status. Status: {}", status);
  }

}