class RedisBackedJobService implements JobService {

  @Override
  public Optional<Job> get(String id) {
    Job job = null;
    try {
      String json = new String(syncCommand.get(id.getBytes()));
      if (json.isEmpty()) {
        return Optional.empty();
      }
      Builder builder = Job.newBuilder();
      JsonFormat.parser().merge(json, builder);
      job = builder.build();
    } catch (Exception e) {
      log.error(String.format("Failed to parse JSON for Feast job: %s", e.getMessage()));
    }
    return Optional.ofNullable(job);
  }

  public  RedisBackedJobService(FeastProperties.JobStoreProperties jobStoreProperties);
  public  RedisBackedJobService(StatefulRedisConnection<byte[], byte[]> connection);

}