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

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

src/a/s/AsyncStageout-HEAD/test/python/AsyncStageOut_t/AsyncTransfer_t.py   AsyncStageout(Download)
        self.config.AsyncTransfer.max_retry = 0
        Analytics = AnalyticsDaemon(config = self.config)
        Analytics.updateWorkflowSummaries()
        query = {}
        state = self.monitoring_db.loadView('UserMonitoring', 'StatesByWorkflow', query)['rows'][0]['value']
        assert state["new"] == 1
        # Run the daemon
        Transfer = TransferDaemon(config = self.config)
        Transfer.algorithm( )
        Analytics.updateWorkflowSummaries()
        assert numberWorkflow == 1
        query = { }
        Analytics.updateWorkflowSummaries()
        state = self.monitoring_db.loadView('UserMonitoring', 'StatesByWorkflow', query)['rows'][0]['value']
        assert state["published"] == 1