Skip to content

Commit

Permalink
removed excessive warning logging
Browse files Browse the repository at this point in the history
  • Loading branch information
codemation committed Jul 20, 2021
1 parent 576b9eb commit a0fa714
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
2 changes: 0 additions & 2 deletions easyrpc/proxy.py
Original file line number Diff line number Diff line change
Expand Up @@ -328,7 +328,6 @@ async def ws_receiver():
try:
while True:
message = await ws.receive()
self.log.warning(f"received message: {message}")
if message.data == None:
break

Expand Down Expand Up @@ -634,7 +633,6 @@ async def make_request():
result = await self.requests[request_id].get()
if not result:
return result
self.log.warning(f"result: {result}")
if hasattr(result, '__contains__') and 'GENERATOR_START' in result:
generator_id = result['GENERATOR_START']
proxy_generator = await self.proxy_generator(request_id, generator_id)
Expand Down
4 changes: 2 additions & 2 deletions easyrpc/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,7 @@ async def ws_sender():
except asyncio.QueueEmpty:
empty = True
continue
self.log.warning(f"ws_sender - request: {request}")

if serialization == 'pickle':
request = serialize(request)
await ws_send(request)
Expand All @@ -291,7 +291,7 @@ async def ws_receiver():
try:
while True:
message = await websocket.receive()
self.log.warning(f"server received message: {message}")

if 'text' in message and 'ping' in message['text']:
await self.server_send_queue[decoded_id].put({'pong': 'pong'})

Expand Down

0 comments on commit a0fa714

Please sign in to comment.