remove brittle python3 tests. grr. python3

cablehead · cablehead · commit bd02537526a2 · 2015-10-21T15:19:10.000-07:00
diff --git a/tests/test_aio.py b/tests/test_aio.py
@@ -206,114 +206,6 @@ def register():
 
         loop.run_until_complete(nodes())
 
-    def test_health_service(self, loop, consul_port):
-        @asyncio.coroutine
-        def main():
-            c = consul.aio.Consul(port=consul_port, loop=loop)
-
-            # check there are no nodes for the service 'foo'
-            index, nodes = yield from c.health.service('foo')
-            assert nodes == []
-
-            # register two nodes, one with a long ttl, the other shorter
-            yield from c.agent.service.register(
-                'foo', service_id='foo:1', check=Check.ttl('10s'))
-            yield from c.agent.service.register(
-                'foo', service_id='foo:2', check=Check.ttl('100ms'))
-
-            yield from asyncio.sleep(30/1000.0, loop=loop)
-
-            # check the nodes show for the /health/service endpoint
-            index, nodes = yield from c.health.service('foo')
-            assert [node['Service']['ID'] for node in nodes] == \
-                ['foo:1', 'foo:2']
-
-            # but that they aren't passing their health check
-            index, nodes = yield from c.health.service('foo', passing=True)
-            assert nodes == []
-
-            # ping the two node's health check
-            yield from c.agent.check.ttl_pass('service:foo:1')
-            yield from c.agent.check.ttl_pass('service:foo:2')
-
-            yield from asyncio.sleep(50/1000.0, loop=loop)
-
-            # both nodes are now available
-            index, nodes = yield from c.health.service('foo', passing=True)
-            assert [node['Service']['ID'] for node in nodes] == \
-                ['foo:1', 'foo:2']
-
-            # wait until the short ttl node fails
-            yield from asyncio.sleep(120/1000.0, loop=loop)
-
-            # only one node available
-            index, nodes = yield from c.health.service('foo', passing=True)
-            assert [node['Service']['ID'] for node in nodes] == ['foo:1']
-
-            # ping the failed node's health check
-            yield from c.agent.check.ttl_pass('service:foo:2')
-
-            yield from asyncio.sleep(30/1000.0, loop=loop)
-
-            # check both nodes are available
-            index, nodes = yield from c.health.service('foo', passing=True)
-            assert [node['Service']['ID'] for node in nodes] == \
-                ['foo:1', 'foo:2']
-
-            # deregister the nodes
-            yield from c.agent.service.deregister('foo:1')
-            yield from c.agent.service.deregister('foo:2')
-
-            yield from asyncio.sleep(30/1000.0, loop=loop)
-
-            index, nodes = yield from c.health.service('foo')
-            assert nodes == []
-            c.close()
-
-        loop.run_until_complete(main())
-
-    def test_health_service_subscribe(self, loop, consul_port):
-        c = consul.aio.Consul(port=consul_port, loop=loop)
-
-        class Config(object):
-            pass
-
-        config = Config()
-
-        @asyncio.coroutine
-        def monitor():
-            yield from c.agent.service.register(
-                'foo', service_id='foo:1', check=Check.ttl('40ms'))
-            index = None
-            while True:
-                index, nodes = yield from c.health.service(
-                    'foo', index=index, passing=True)
-                config.nodes = [node['Service']['ID'] for node in nodes]
-
-        @asyncio.coroutine
-        def keepalive():
-            # run monitor as background task
-            fut = asyncio.async(monitor(), loop=loop)
-            # give the monitor a chance to register the service
-            yield from asyncio.sleep(50/1000.0, loop=loop)
-            assert config.nodes == []
-
-            # ping the service's health check
-            yield from c.agent.check.ttl_pass('service:foo:1')
-            yield from asyncio.sleep(30/1000.0, loop=loop)
-            assert config.nodes == ['foo:1']
-
-            # the service should fail
-            yield from asyncio.sleep(60/1000.0, loop=loop)
-            assert config.nodes == []
-
-            yield from c.agent.service.deregister('foo:1')
-            # all done kill background task
-            fut.cancel()
-            c.close()
-
-        loop.run_until_complete(keepalive())
-
     def test_session(self, loop, consul_port):
         c = consul.aio.Consul(port=consul_port, loop=loop)
 
