Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(7)  |  Call(4)  |  Derive(0)  |  Import(3)

src/c/r/CRABServer-HEAD/src/python/TaskWorker/Actions/PreJob.py   CRABServer(Download)
import re
 
from ApmonIf import ApmonIf
 
states = ['OK', 'FATAL_ERROR', 'RECOVERABLE_ERROR']
                 }
 
        apmon = ApmonIf()
        print("Dashboard task info: %s" % str(params))
        apmon.sendToML(params)

src/c/r/CRABServer-HEAD/src/python/TaskWorker/Actions/DagmanSubmitter.py   CRABServer(Download)
from TaskWorker.WorkerExceptions import TaskWorkerException
 
from ApmonIf import ApmonIf
 
# Bootstrap either the native module or the BossAir variant.
    def sendDashboardJobs(self, params, info):
        apmon = ApmonIf()
        for job in info:
            job.update(params)
            self.logger.debug("Dashboard job info: %s" % str(job))

src/c/r/CRABServer-HEAD/src/python/TaskWorker/Actions/DagmanCreator.py   CRABServer(Download)
    UserFileCache = None
 
from ApmonIf import ApmonIf
 
DAG_HEADER = """
    def sendDashboardTask(self):
        apmon = ApmonIf()
        params = self.buildDashboardInfo()
        params_copy = dict(params)
        params_copy['jobId'] = 'TaskMeta'

src/c/r/CRABServer-HEAD/src/python/TaskWorker/Actions/DagmanKiller.py   CRABServer(Download)
    def execute(self, *args, **kw):
 
        apmon = ApmonIf.ApmonIf()
        try:
            self.executeInternal(apmon, *args, **kw)