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

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

src/a/s/AsyncStageout-HEAD/src/python/AsyncStageOut/PublisherDaemon.py   AsyncStageout(Download)
from WMCore.Database.CMSCouch import CouchServer
from WMCore.WorkerThreads.BaseWorkerThread import BaseWorkerThread
from AsyncStageOut.PublisherWorker import PublisherWorker
from multiprocessing import Pool
from WMCore.WMFactory import WMFactory
    logging.debug("Trying to start the worker")
    try:
        worker = PublisherWorker(user, config)
    except Exception, e:
        logging.debug("Worker cannot be created!:" %e)
        return user
    if worker.init:
       logging.debug("Starting %s" %worker)
       try:
           worker ()

src/a/s/AsyncStageout-HEAD/test/python/AsyncStageOut_t/StandaloneDBS3Publication.py   AsyncStageout(Download)
    def setUp(self):
        self.publisher = AsyncStageOut.PublisherWorker.PublisherWorker((TEST_USER, TEST_GROUP, TEST_ROLE), self.config.DBSPublisher)
 
    def getConfig(self):
        """