Update main.py

main.py

@@ -233,13 +233,13 @@ thread.start()
 #lithening to changes of documnts
 callback_done = threading.Event()
 def on_snapshot(doc_snapshot, changes, read_time):
+    global queuedUnSummurizedShawkas
+    global semphoreShakwas
     for doc in doc_snapshot:
         # print(doc.to_dict())
         shakw = Classes.Shakwa.from_dict(source=doc.to_dict())
         shakw.complaintbody
-        if shakw.summary==None:
-            global queuedUnSummurizedShawkas
-            global semphoreShakwas
+        if shakw.summary==None and shakw not in queuedUnSummurizedShawkas :
             queuedUnSummurizedShawkas.append(shakw)
             semphoreShakwas.release()
     callback_done.set()