Function create_arbiter

benchmarks/dirty_streaming.py:147–158

Create a test arbiter for benchmarks.

()

def create_arbiter():
    """Create a test arbiter for benchmarks."""
    cfg = Config()
    cfg.set("dirty_timeout", 300)
    log = MockLog()

    arbiter = DirtyArbiter(cfg=cfg, log=log)
    arbiter.alive = True
    arbiter.workers = {1234: mock.Mock()}
    arbiter.worker_sockets = {1234: '/tmp/worker.sock'}

    return arbiter


class BenchmarkResults: