Spaces:
Sleeping
Sleeping
Update controllers/ws_controller.py
Browse files
controllers/ws_controller.py
CHANGED
@@ -69,8 +69,8 @@ async def get_messages(code: str,websocket:WebSocket,start,brand_name: Optional[
|
|
69 |
|
70 |
futures=[executor.submit(fetch_message_wrapper, message_data,websocket) for message_data in
|
71 |
gmail_data["messages"]]
|
72 |
-
print(len(futures))
|
73 |
-
print(futures)
|
74 |
for future in concurrent.futures.as_completed(futures):
|
75 |
message = future.result()
|
76 |
# print(message)
|
@@ -84,9 +84,9 @@ async def get_messages(code: str,websocket:WebSocket,start,brand_name: Optional[
|
|
84 |
|
85 |
# if message:
|
86 |
# messages.append(message)
|
87 |
-
print("Messages to be sent")
|
88 |
-
print(messages)
|
89 |
-
print(len(messages))
|
90 |
# for message_data in messages:
|
91 |
# await process_message(message_data,websocket,10000)
|
92 |
|
@@ -95,8 +95,8 @@ async def get_messages(code: str,websocket:WebSocket,start,brand_name: Optional[
|
|
95 |
page_token = gmail_data["nextPageToken"]
|
96 |
else:
|
97 |
break
|
98 |
-
print("printing messages")
|
99 |
-
print(messages)
|
100 |
return messages
|
101 |
|
102 |
async def process_message(message:Message, websocket:WebSocket, chunk_size:int):
|
|
|
69 |
|
70 |
futures=[executor.submit(fetch_message_wrapper, message_data,websocket) for message_data in
|
71 |
gmail_data["messages"]]
|
72 |
+
# print(len(futures))
|
73 |
+
# print(futures)
|
74 |
for future in concurrent.futures.as_completed(futures):
|
75 |
message = future.result()
|
76 |
# print(message)
|
|
|
84 |
|
85 |
# if message:
|
86 |
# messages.append(message)
|
87 |
+
# print("Messages to be sent")
|
88 |
+
# print(messages)
|
89 |
+
# print(len(messages))
|
90 |
# for message_data in messages:
|
91 |
# await process_message(message_data,websocket,10000)
|
92 |
|
|
|
95 |
page_token = gmail_data["nextPageToken"]
|
96 |
else:
|
97 |
break
|
98 |
+
# print("printing messages")
|
99 |
+
# print(messages)
|
100 |
return messages
|
101 |
|
102 |
async def process_message(message:Message, websocket:WebSocket, chunk_size:int):
|