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

All Samples(4)  |  Call(2)  |  Derive(0)  |  Import(2)

src/a/s/AsyncStageout-HEAD/src/python/AsyncStageOut/Analytics.py   AsyncStageout(Download)
"""
from WMCore.Agent.Harness import Harness
from AsyncStageOut.AnalyticsDaemon import AnalyticsDaemon
import logging
import threading
                       %str(self.config.Analytics.analyticsPollingInterval) )
        myThread.workerThreadManager.addWorker( \
                              AnalyticsDaemon(self.config), \
                              self.config.Analytics.analyticsPollingInterval \
                            )

src/a/s/AsyncStageout-HEAD/test/python/AsyncStageOut_t/AsyncTransfer_t.py   AsyncStageout(Download)
from AsyncStageOut.LFNSourceDuplicator import LFNSourceDuplicator
from AsyncStageOut.TransferWorker import TransferWorker
from AsyncStageOut.AnalyticsDaemon import AnalyticsDaemon
from AsyncStageOut.StatisticDaemon import StatisticDaemon
from WMCore.Configuration import loadConfigurationFile
        self.createFileDocinFilesDB()
        self.config.AsyncTransfer.max_retry = 0
        Analytics = AnalyticsDaemon(config = self.config)
        Analytics.updateWorkflowSummaries()
        query = {}