co.cask.coopr.scheduler.task

Class TaskService

java.lang.Object

co.cask.coopr.scheduler.task.TaskService

public class TaskService
extends Object

Service for performing operations on ClusterTasks.

Method Summary

Methods

Modifier and Type	Method and Description
void	completeJob(ClusterJob job, Cluster cluster) Sets the status of the given job to ClusterJob.Status.COMPLETE and the status of the given cluster to Cluster.Status.ACTIVE.
void	completeTask(ClusterTask clusterTask, int status) Complete a task by setting the status of the task to ClusterTask.Status.COMPLETE and the status time to the current timestamp and the status code to the given code.
void	dropTask(ClusterTask clusterTask) Drop a task by setting the status of the task to ClusterTask.Status.DROPPED and the status time to the current timestamp.
void	failJob(ClusterJob job) Sets the status of the given job to ClusterJob.Status.FAILED and persists it to the store.
void	failJobAndSetClusterStatus(ClusterJob job, Cluster cluster) Sets the status of the given job to ClusterJob.Status.FAILED and the status of the cluster to the default failure status as given in ClusterAction.getFailureStatus().
void	failJobAndSetClusterStatus(ClusterJob job, Cluster cluster, Cluster.Status status, String message) Sets the status of the given job to ClusterJob.Status.FAILED and the status of the cluster to some given status.
void	failJobAndTerminateCluster(ClusterJob job, Cluster cluster, String message) Sets the status of the given job to ClusterJob.Status.FAILED and the status of the given cluster to Cluster.Status.TERMINATED.
void	failTask(ClusterTask clusterTask, int status) Fail a task by setting the status of the task to ClusterTask.Status.FAILED and the status time to the current timestamp and the status code to the given code.
List<ClusterTask>	getRetryTask(ClusterTask task) Get tasks that must be run in order to retry the given task that failed on a given node in a given cluster.
void	startJob(ClusterJob job, Cluster cluster) Sets the status of the given job to ClusterJob.Status.RUNNING and add it to the queue to be run.
void	startTask(ClusterTask clusterTask) Starts a task by setting the status of the task to ClusterTask.Status.IN_PROGRESS and the submit time to the current timestamp.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getRetryTask

public List<ClusterTask> getRetryTask(ClusterTask task)

Get tasks that must be run in order to retry the given task that failed on a given node in a given cluster. For example, to retry a service installation, we just retry the task again. However, to retry a node confirm, we need to first delete the created node, create another node, and then confirm that node.

Parameters:

task - Task that failed and must be retried.

Returns:

List of tasks that must be executed to retry the given failed task.

failJobAndSetClusterStatus

public void failJobAndSetClusterStatus(ClusterJob job,
                              Cluster cluster,
                              Cluster.Status status,
                              String message)
                                throws IOException,
                                       IllegalAccessException

Sets the status of the given job to ClusterJob.Status.FAILED and the status of the cluster to some given status.

Parameters:

job - Job to fail.

cluster - Cluster to set the status for.

status - Status to set the cluster to.

message - Error message.

Throws:

IOException

IllegalAccessException

failJobAndSetClusterStatus

public void failJobAndSetClusterStatus(ClusterJob job,
                              Cluster cluster)
                                throws IOException,
                                       IllegalAccessException

Sets the status of the given job to ClusterJob.Status.FAILED and the status of the cluster to the default failure status as given in ClusterAction.getFailureStatus().

Parameters:

job - Job to fail.

cluster - Cluster to set the status for.

Throws:

IOException

IllegalAccessException

failJobAndTerminateCluster

public void failJobAndTerminateCluster(ClusterJob job,
                              Cluster cluster,
                              String message)
                                throws IOException,
                                       IllegalAccessException

Sets the status of the given job to ClusterJob.Status.FAILED and the status of the given cluster to Cluster.Status.TERMINATED.

Parameters:

job - Job to fail.

cluster - Cluster to terminate.

message - Error message.

Throws:

IOException

IllegalAccessException

failJob

public void failJob(ClusterJob job)
             throws IOException

Sets the status of the given job to ClusterJob.Status.FAILED and persists it to the store.

Parameters:

job - Job to fail.

Throws:

IOException

startJob

public void startJob(ClusterJob job,
            Cluster cluster)
              throws IOException

Sets the status of the given job to ClusterJob.Status.RUNNING and add it to the queue to be run.

Parameters:

job - Job to start.

cluster - Cluster the job is for.

Throws:

IOException

completeJob

public void completeJob(ClusterJob job,
               Cluster cluster)
                 throws IOException,
                        IllegalAccessException

Sets the status of the given job to ClusterJob.Status.COMPLETE and the status of the given cluster to Cluster.Status.ACTIVE.

Parameters:

job - Job to complete.

cluster - Cluster the job was for.

Throws:

IOException

IllegalAccessException

startTask

public void startTask(ClusterTask clusterTask)
               throws IOException

Starts a task by setting the status of the task to ClusterTask.Status.IN_PROGRESS and the submit time to the current timestamp.

Parameters:

clusterTask - Task to start.

Throws:

IOException

dropTask

public void dropTask(ClusterTask clusterTask)
              throws IOException

Drop a task by setting the status of the task to ClusterTask.Status.DROPPED and the status time to the current timestamp. Tasks can be dropped if there is no longer any point in executing them. For example, if another task in the same stage has failed, the entire job cannot complete so there is no point in executing any unexecuted task in the job.

Parameters:

clusterTask - Task to drop.

Throws:

IOException

failTask

public void failTask(ClusterTask clusterTask,
            int status)
              throws IOException

Fail a task by setting the status of the task to ClusterTask.Status.FAILED and the status time to the current timestamp and the status code to the given code.

Parameters:

clusterTask - Task to fail.

status - Status code of the failed task.

Throws:

IOException

completeTask

public void completeTask(ClusterTask clusterTask,
                int status)
                  throws IOException

Complete a task by setting the status of the task to ClusterTask.Status.COMPLETE and the status time to the current timestamp and the status code to the given code.

Parameters:

clusterTask - Task to complete.

status - Status code of the completed task.

Throws:

IOException