mirror of https://github.com/DJ2LS/FreeDATA.git
Fixed ruff F541
parent
8f7113fd3e
commit
ed4c79cd2a
|
|
@ -583,4 +583,4 @@ async def patch_freedata_broadcast_domain(id: str, payload: dict, ctx: AppContex
|
|||
@router.post("/broadcasts", summary="Transmit Broadcast", tags=["FreeDATA"], responses={})
|
||||
async def post_freedata_broadcast(payload: dict, ctx: AppContext = Depends(get_ctx)):
|
||||
await enqueue_tx_command(ctx, command_norm.Norm, payload)
|
||||
return api_response({"message": f"broadcast transmitted", "status": "success"})
|
||||
return api_response({"message": "broadcast transmitted", "status": "success"})
|
||||
|
|
|
|||
|
|
@ -51,7 +51,7 @@ class wsm:
|
|||
event_queue (queue.Queue): The event queue. Currently unused.
|
||||
"""
|
||||
client_list.add(websocket)
|
||||
self.log.info(f"Client websocket connection established", ws=websocket)
|
||||
self.log.info("Client websocket connection established", ws=websocket)
|
||||
while not self.shutdown_flag.is_set():
|
||||
try:
|
||||
await websocket.receive_text()
|
||||
|
|
|
|||
|
|
@ -95,7 +95,7 @@ class TestMessageProtocol(unittest.TestCase):
|
|||
if ctx_b:
|
||||
for burst in transmission:
|
||||
ctx_b.TESTMODE_RECEIVE_QUEUE.put(burst)
|
||||
self.logger.info(f"Data forwarded to Station B")
|
||||
self.logger.info("Data forwarded to Station B")
|
||||
|
||||
frame_bytes = transmission[1]
|
||||
if len(frame_bytes) == 5:
|
||||
|
|
|
|||
Loading…
Reference in New Issue