PilotJob.h

 
#ifndef WRENCH_PILOTJOB_H
#define WRENCH_PILOTJOB_H
 
 
#include "wrench/workflow/job/WorkflowJob.h"
#include "wrench/services/compute/ComputeService.h"
 
namespace wrench {
 
    class ComputeService;
 
    /***********************/
    /***********************/
 
    class PilotJob : public WorkflowJob {
 
    public:
 
        enum State {
            NOT_SUBMITTED,
            PENDING,
            RUNNING,
            EXPIRED,
            FAILED,
            TERMINATED
        };
 
        std::shared_ptr<ComputeService> getComputeService();
 
        PilotJob::State getState();
 
        unsigned long getPriority();
 
        /***********************/
        /***********************/
 
 
        void setComputeService(std::shared_ptr<ComputeService> cs);
 
        /***********************/
        /***********************/
 
    private:
 
        friend class JobManager;
 
        PilotJob(Workflow *workflow);
 
        State state;
        std::shared_ptr<ComputeService> compute_service; // Associated compute service, i.e., the running pilot job
    };
 
    /***********************/
    /***********************/
 
};
 
 
#endif //WRENCH_PILOTJOB_H