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

All Samples(8)  |  Call(6)  |  Derive(0)  |  Import(2)

src/a/s/AsyncStageout-HEAD/src/python/AsyncStageOut/AsyncTransfer.py   AsyncStageout(Download)
"""
from WMCore.Agent.Harness import Harness
from AsyncStageOut.TransferDaemon import TransferDaemon
#from AsyncStageOut.LFNSourceDuplicator import LFNSourceDuplicator
from AsyncStageOut import execute_command
 
        myThread.workerThreadManager.addWorker( \
                              TransferDaemon(self.config), \
                              self.config.AsyncTransfer.pollInterval \
                            )

src/a/s/AsyncStageout-HEAD/test/python/AsyncStageOut_t/AsyncTransfer_t.py   AsyncStageout(Download)
import urllib
 
from AsyncStageOut.TransferDaemon import TransferDaemon
from AsyncStageOut.PublisherDaemon import PublisherDaemon
from AsyncStageOut.LFNSourceDuplicator import LFNSourceDuplicator
        """
        self.createFileDocinFilesDB()
        Transfer = TransferDaemon(config = self.config)
        Transfer.algorithm( )
        query = {'reduce':False}
        assert len(active_files) == 1
 
        Transfer = TransferDaemon(config = self.config)
        Transfer.algorithm( )
        query = {'reduce':False}
        assert len(active1_files) == 5
 
        Transfer_1 = TransferDaemon(config = self.config)
        Transfer_1.algorithm( )
        query = {'reduce':False}
        time.sleep(10)
        # Run the daemon
        Transfer = TransferDaemon(config = self.config)
        Transfer.algorithm( )
        query = {'reduce':False}