job

Sep 10, 2023

Changes in this version

+ var ErrJobFinished = errors.New("job already finished")

+ var ErrJobIsNotRunning = errors.New("job is not running")

+ var ErrJobRunning = errors.New("job already running")

+ type Job struct

+ Command string

+ DAG *dag.DAG

+ EngineFactory engine.Factory

+ Next time.Time

+ WorkDir string

+ func (j *Job) GetDAG() *dag.DAG

+ func (j *Job) Restart() error

+ func (j *Job) Start() error

+ func (j *Job) Stop() error

+ func (j *Job) String() string