@@ -106,10 +106,16 @@ class AsyncTransportProtocolErrorHandler(AsyncTransport):
106106
107107 @retry_connection_error (attempts = 2 , exception = httpx .RemoteProtocolError )
108108 async def post (self , address , message , headers ):
109+ import pprint
110+
111+ pprint .pprint (["post" , address , message , headers ])
109112 return await super ().post (address , message , headers )
110113
111114 @retry_connection_error (attempts = 2 , exception = httpx .RemoteProtocolError )
112115 async def get (self , address , params , headers ):
116+ import pprint
117+
118+ pprint .pprint (["get" , address , params , headers ])
113119 return await super ().get (address , params , headers )
114120
115121
@@ -240,7 +246,7 @@ def __init__(
240246 verify = _NO_VERIFY_SSL_CONTEXT , timeout = timeouts , limits = _HTTPX_LIMITS
241247 )
242248 self .transport = (
243- AsyncTransport (client = client , wsdl_client = wsdl_client )
249+ AsyncTransportProtocolErrorHandler (client = client , wsdl_client = wsdl_client )
244250 if no_cache
245251 else AsyncTransportProtocolErrorHandler (
246252 client = client , wsdl_client = wsdl_client , cache = SqliteCache ()
0 commit comments