Skip to content

Commit 0bdac0a

Browse files
committed
always use the error handling transport
1 parent f6800c3 commit 0bdac0a

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

onvif/client.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)