Package ubic.gemma.core.job
Interface TaskRunningService
-
- All Superinterfaces:
io.micrometer.core.instrument.binder.MeterBinder
- All Known Implementing Classes:
TaskRunningServiceImpl
public interface TaskRunningService extends io.micrometer.core.instrument.binder.MeterBinder
- Author:
- paul, anton
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description SubmittedTask
getSubmittedTask(String taskId)
Collection<SubmittedTask>
getSubmittedTasks()
<T extends Task<?>>
StringsubmitTask(T task)
<C extends TaskCommand>
StringsubmitTaskCommand(C taskCommand)
Submit a task and track its progress.
-
-
-
Method Detail
-
getSubmittedTask
SubmittedTask getSubmittedTask(String taskId)
-
getSubmittedTasks
Collection<SubmittedTask> getSubmittedTasks()
- Returns:
- the submittedTasks
-
submitTaskCommand
<C extends TaskCommand> String submitTaskCommand(C taskCommand)
Submit a task and track its progress. When it is finished, the results can be retrieved with checkResult(). Tasks can be cancelled with cancelTask().- Type Parameters:
C
- task command implementation- Parameters:
taskCommand
- The command to run. The submissionTime of the task is set after this call. This does not mean that the job has started - it might be queued.- Returns:
- string
-
-