public class LocalJobRunner extends java.lang.Object implements JobSubmitterService
Constructor and Description |
---|
LocalJobRunner(@NotNull JobPersistenceService jobPersistenceService,
@NonNull GenieEventBus genieEventBus,
@NotNull java.util.List<WorkflowTask> workflowTasks,
@NotNull org.springframework.core.io.Resource genieWorkingDir,
@NotNull io.micrometer.core.instrument.MeterRegistry registry)
Constructor create the object.
|
Modifier and Type | Method and Description |
---|---|
void |
submitJob(@NotNull(message="No job provided. Unable to submit job for execution.") @Valid JobRequest jobRequest,
@NotNull(message="No cluster provided. Unable to submit job for execution") @Valid Cluster cluster,
@NotNull(message="No command provided. Unable to submit job for execution") @Valid Command command,
@NotNull(message="No applications provided. Unable to execute") java.util.List<Application> applications,
@Min(value=1L,message="Memory can\'t be less than 1 MB") int memory)
Submit the job for appropriate execution based on environment.
|
public LocalJobRunner(@NotNull @NotNull JobPersistenceService jobPersistenceService, @NonNull @NonNull GenieEventBus genieEventBus, @NotNull @NotNull java.util.List<WorkflowTask> workflowTasks, @NotNull @NotNull org.springframework.core.io.Resource genieWorkingDir, @NotNull @NotNull io.micrometer.core.instrument.MeterRegistry registry)
jobPersistenceService
- Implementation of the job persistence servicegenieEventBus
- The event bus implementation to useworkflowTasks
- List of all the workflow tasks to be executedgenieWorkingDir
- Working directory for genie where it creates jobs directoriesregistry
- The metrics registry to usepublic void submitJob(@NotNull(message="No job provided. Unable to submit job for execution.") @Valid @NotNull(message="No job provided. Unable to submit job for execution.") @Valid JobRequest jobRequest, @NotNull(message="No cluster provided. Unable to submit job for execution") @Valid @NotNull(message="No cluster provided. Unable to submit job for execution") @Valid Cluster cluster, @NotNull(message="No command provided. Unable to submit job for execution") @Valid @NotNull(message="No command provided. Unable to submit job for execution") @Valid Command command, @NotNull(message="No applications provided. Unable to execute") @NotNull(message="No applications provided. Unable to execute") java.util.List<Application> applications, @Min(value=1L,message="Memory can\'t be less than 1 MB") @Min(value=1L,message="Memory can\'t be less than 1 MB") int memory) throws GenieException
submitJob
in interface JobSubmitterService
jobRequest
- of job to runcluster
- The cluster this job should run oncommand
- the command to run this job withapplications
- Any applications that are needed to run the commandmemory
- The amount of memory (in MB) to use to run the jobGenieException
- if there is an error