Scott.Idem/OSIT-AE-API-FastAPI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Less debug

Browse Source
This commit is contained in:
Scott Idem
2024-10-08 14:03:00 -04:00
parent e6e7275de0
commit c798b4659f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
app/routers/websockets_redis.py
View File

@@ -96,7 +96,7 @@ async def redis_connector(
group_id = None, group_id = None,
): ):
log.setLevel(logging.INFO) log.setLevel(logging.INFO)
log.info('sender_handler()') log.info(f'sender_handler() {r_channel} {ws_conn} {client_id} {group_id}')
try: try:
while True: while True:
@@ -131,7 +131,7 @@ async def redis_connector(
# await ws_conn.send_json(data) # await ws_conn.send_json(data)
send_flag = True send_flag = True
elif group_id: elif group_id:
log.info('WS group: Skip sending to client') log.debug('WS group: Skip sending to client')
send_flag = False send_flag = False
# continue # Do not send # continue # Do not send
@@ -139,7 +139,7 @@ async def redis_connector(
log.info('Sending echo to client') log.info('Sending echo to client')
send_flag = True send_flag = True
elif data.get('target') == 'echo': elif data.get('target') == 'echo':
log.info('WS echo: Skip sending to client') log.debug('WS echo: Skip sending to client')
send_flag = False send_flag = False
# continue # continue
@@ -149,7 +149,7 @@ async def redis_connector(
# await ws_conn.send_json(data) # await ws_conn.send_json(data)
if send_flag: if send_flag:
log.info('Sending!') log.debug('Sending!')
await ws_conn.send_json(data) await ws_conn.send_json(data)
else: else:
log.info('Not sending') log.info('Not sending')