@@ -50,7 +50,7 @@ def sse_response_for_user(user_id: str):
|
|||||||
# Generate unique connection ID
|
# Generate unique connection ID
|
||||||
connection_id = str(uuid.uuid4())
|
connection_id = str(uuid.uuid4())
|
||||||
user_queue = get_queue(user_id, connection_id)
|
user_queue = get_queue(user_id, connection_id)
|
||||||
logger.info(f"SSE response for {user_id} user is {user_queues.keys()}")
|
logger.info(f"SSE response for {user_id} user is {user_queue}")
|
||||||
|
|
||||||
def generate():
|
def generate():
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user