JobState.py

Go to the documentation of this file.

# JobState
#
# This package maintains a primitive database of the pending, running,
# and completed jobs.
#
# Created by dandwyer@caltech.edu 2010/08/09

import ProcessManager.Status as Status

class State: 
    UNKNOWN=0

    RUN_READY=1
    RUN_PROCESSING=2
    RUN_DONE=3
    RUN_FAILED=4

    STATS_UNKNOWN=5
    STATS_READY=6
    STATS_ADDING=7
    STATS_DONE=8
    STATS_FAILED=9

    SUMMARY_UNKNOWN=10
    SUMMARY_READY=11
    SUMMARY_PRINTING=12
    SUMMARY_PRINTED=13
    SUMMARY_INDEXING=14
    SUMMARY_INDEXED=15
    SUMMARY_ADDING=16
    SUMMARY_DONE=17
    SUMMARY_FAILED_PRINTING=18
    SUMMARY_FAILED_INDEXING=19
    SUMMARY_FAILED_ADDING=20

    DQDUMP_READY=21
    DQDUMP_PMTPROCESSING=22
    DQDUMP_PMTDONE=23
    DQDUMP_PMTFAILED=24
    DQDUMP_TRIGGERPROCESSING=25
    DQDUMP_TRIGGERDONE=26
    DQDUMP_TRIGGERFAILED=27
    DQDUMP_RATEDONE=28
    DQDUMP_RATEFAILED=29
    DQDUMP_PROCESSING=30
    DQDUMP_FAILED=31
    DQDUMP_DONE=32


    @classmethod
    def getStateByName(cls, name):
        """Return the state with the given name"""
        if hasattr(cls, name):
            return getattr(cls, name)
        return State.UNKNOWN

    @classmethod
    def getName(cls, state):
        """Return the name for a given state"""
        for name in dir(cls):
            if name.startswith("__"):
                continue
            if getattr(cls,name)==state:
                return name
        return "UNKNOWN"
            
class JobState:
    """State of the given job"""
    def __init__(self,state=State.UNKNOWN,time=0):
        """ Initialize Job State """
        self.state=state
        self.time=time

class JobType:
    """Types of Jobs"""
    RUN="run"
    ADDSTATS="addStats"
    SUMMARY="summary"
    DQDUMP="dqDump"