e363904af067de1beac98313c0a6f8362980d406,distributed/tests/test_scheduler.py,,test_service_hosts,#,1138

Before Change

    pytest.importorskip("bokeh")
    from distributed.bokeh.scheduler import BokehScheduler

    for port in [0, ("127.0.0.3", 0)]:
        for url, expected in [("tcp://0.0.0.0", ("::", "0.0.0.0")),
                              ("tcp://127.0.0.2", "127.0.0.2"),
                              ("tcp://127.0.0.2:38275", "127.0.0.2")]:
            services = {("bokeh", port): BokehScheduler}

            s = Scheduler(services=services)
            yield s.start(url)

            sock = first(s.services["bokeh"].server._http._sockets.values())
            if isinstance(port, tuple):    // host explicitly overridden
                assert sock.getsockname()[0] == port[0]
            elif isinstance(expected, tuple):
                assert sock.getsockname()[0] in expected
            else:
                assert sock.getsockname()[0] == expected
            yield s.close()


@gen_cluster(client=True, worker_kwargs={"profile_cycle_interval": 100})
def test_profile_metadata(c, s, a, b):
    start = time() - 1
    futures = c.map(slowinc, range(10), delay=0.05, workers=a.address)

After Change

            assert sock.getsockname()[0] == expected
        yield s.close()

    port = ("127.0.0.1", 0)
    for url in ["tcp://0.0.0.0", "tcp://127.0.0.1", "tcp://127.0.0.1:38275"]:
        services = {("bokeh", port): BokehScheduler}

        s = Scheduler(services=services)
        yield s.start(url)

        sock = first(s.services["bokeh"].server._http._sockets.values())
        assert sock.getsockname()[0] == "127.0.0.1"
        yield s.close()

Instances