class DirectRunnerJobManager implements JobManager {

  @Override
  public Job abortJob(Job job) {
    DirectJob directJob = jobs.get(job.getExtId());
    if (directJob != null) {
      try {
        directJob.abort();
      } catch (IOException e) {
        throw new RuntimeException(
            Strings.lenientFormat("Unable to abort DirectRunner job %s", job.getExtId(), e));
      }
      jobs.remove(job.getExtId());
    }

    return job;
  }

  public  DirectRunnerJobManager(
      DirectRunnerConfigOptions directRunnerConfigOptions,
      DirectJobRegistry jobs,
      MetricsProperties metricsProperties,
      IngestionJobProto.SpecsStreamingUpdateConfig specsStreamingUpdateConfig);

}