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/TransferWorker.py   AsyncStageout(Download)
from WMCore.Credential.Proxy import Proxy
from AsyncStageOut import getHashLfn
from AsyncStageOut import getFTServer
from AsyncStageOut import getDNFromUserName
#import json
                tmp_file_pool.append(tmp_copyjob_file.name)
 
                fts_server_for_transfer = getFTServer(link[1], 'getRunningFTSserver', self.config_db, self.logger)
                ftslog_file = open('%s/%s-%s_%s.ftslog' % ( self.log_dir, link[0], link[1], str(time.time()) ), 'w')
 

src/a/s/AsyncStageout-HEAD/src/python/AsyncStageOut/StatisticDaemon.py   AsyncStageout(Download)
from WMCore.Database.CMSCouch import CouchServer
from WMCore.WorkerThreads.BaseWorkerThread import BaseWorkerThread
from AsyncStageOut import getFTServer
 
import datetime
        Update the stat documents list.
        """
        ftserver = getFTServer(document['destination'], 'getAllFTSserver', self.config_db, self.logger)
 
        for oldDoc in self.iteration_docs: