debug

Author: blink1073

test/asynchronous/test_srv_polling.py

@@ -177,7 +177,7 @@ def dns_resolver_response():
         with SrvPollingKnobs(ttl_time=WAIT_TIME, min_srv_rescan_interval=WAIT_TIME):
             client = self.simple_client(self.CONNECTION_STRING)
             await client.aconnect()
-            await assertion_method(self.BASE_SRV_RESPONSE, client)
+            await self.assert_nodelist_change(self.BASE_SRV_RESPONSE, client)
             # Patch list of hosts returned by DNS query.
             with SrvPollingKnobs(
                 nodelist_callback=dns_resolver_response, count_resolver_calls=count_resolver_calls
@@ -219,6 +219,8 @@ async def test_dns_failures(self):
             def response_callback(*args):
                 raise exc("DNS Failure!")
 
+            print(exc)
+
             await self.run_scenario(response_callback, False)
 
     async def test_dns_record_lookup_empty(self):

test/test_srv_polling.py

@@ -177,7 +177,7 @@ def dns_resolver_response():
         with SrvPollingKnobs(ttl_time=WAIT_TIME, min_srv_rescan_interval=WAIT_TIME):
             client = self.simple_client(self.CONNECTION_STRING)
             client._connect()
-            assertion_method(self.BASE_SRV_RESPONSE, client)
+            self.assert_nodelist_change(self.BASE_SRV_RESPONSE, client)
             # Patch list of hosts returned by DNS query.
             with SrvPollingKnobs(
                 nodelist_callback=dns_resolver_response, count_resolver_calls=count_resolver_calls
@@ -219,6 +219,8 @@ def test_dns_failures(self):
             def response_callback(*args):
                 raise exc("DNS Failure!")
 
+            print(exc)
+
             self.run_scenario(response_callback, False)
 
     def test_dns_record_lookup_empty(self):