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

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

src/t/e/testrunner-HEAD/pysystests/app/workload_manager.py   testrunner(Download)
def postcondition_handler():
 
    workloads = CacheHelper.workloads()
    for workload in workloads:
        if workload.postcondition_handler and workload.active:
    ip, port = host.split(':')
 
    workloads = CacheHelper.workloads()
    for workload in workloads:
        if workload.active and workload.bucket == bucket:
def throttle_kv_ops(isovercommited=True):
 
    rabbitHelper = kv_ops_manager.rabbitHelper
 
    workloads = CacheHelper.workloads()

src/t/e/testrunner-HEAD/pysystests/app/query.py   testrunner(Download)
def updateQueryWorkload(query):
    workloads = CacheHelper.workloads()
 
    for workload in workloads:
        if workload.active and workload.bucket == query.bucket: