Cross Reference: /ec/ECSpooler/lib/Spooler.py

Lines Matching refs:LOG
24 LOG = logging.getLogger()
62         LOG.debug('Using job store %s' % config.JOB_QUEUE_STORAGE)
66         LOG.debug("Using result store %s" % config.RESULT_QUEUE_STORAGE)
70         LOG.debug("Using retry store %s" % config.RETRY_QUEUE_STORAGE)
111         LOG.info('Starting scheduler thread (%s)...' % self._className)
124         LOG.info('Stopping scheduler thread (%s)...' % self._className)
128             LOG.debug('Scheduler thread is still alive, waiting %ds' %
132         LOG.info('Stopping backends...')
171 #                LOG.info("Stopping backend '%s' at '%s'" % (uid, backend['url']))
214         LOG.info("Backend '%s %s (%s) (%s)' registered" % 
242                     LOG.info("Unregistering backend '%s %s (%s) (%s)'..." % 
256             LOG.info("Backend '%s (%s)' unregistered" % (backendId, url))
294                 LOG.warn("No such backend: %s" % backenId)
298             LOG.info("Enqueueing job '%s'" % job.getId())
305             LOG.error(msg)
324         LOG.debug("Dequeuing results for all jobs (%d)" % self._results.getSize())
328             LOG.info("Returning result for job '%s'" % item.getId())
359         LOG.debug("Dequeuing result for job '%s'" % jobId)
363             LOG.info("Returning result for job '%s'" % jobId)
366             LOG.info("No result for job '%s'" % jobId)
383         LOG.debug('Returning spooler status information')
405         LOG.debug('Returning spooler PID')
423         LOG.debug('Returning all available backends')
451         LOG.debug("Trying to return status information for backend '%s'" % backendId)
483         LOG.debug("Trying to return input fields for backend '%s'" % backendId)
517         LOG.debug("Trying to return test specs for backend '%s'" % backendId)
549             LOG.warn(msg)
589                             LOG.info('Backend %s is busy (%s)' % 
595                             LOG.info("Adding job to retry queue: %s" % job.getId())
606                         LOG.warn("Job %s can not be executed, no such "
616                     #LOG.debug('_doqueue: self._queue is empty');
621                 LOG.error(msg)
640             LOG.info("Dispatching job '%s' to backend '%s'" % 
656                 LOG.error(msg)
661             LOG.error(msg)
666         LOG.info("Result of job '%s' added to result queue" % (result.getId(),))
673         #LOG.debug('jobId: %s' % job.getId())
674         #LOG.debug('data: %s' % result.getData())
687             LOG.debug("Moving %d job(s) back from 'retry queue' to 'default queue'." 
703         #LOG.debug('xxx: %s' % repr(kw))
704         #LOG.debug("xmlrpclib.Server('%s')" % (url))
709             #LOG.debug('_callBackend: %s' % repr(result))
714             LOG.error(traceback.format_exc())