temporary

Author: amadolid

jaseci_ai_kit/jac_misc/jac_misc/scraper/utils.py

@@ -11,15 +11,24 @@ class Stopped(Exception):
     @staticmethod
     def add(trigger_id: str):
         Process.queue.add(trigger_id)
+        print(Process.queue)
 
     @staticmethod
     def can_continue(trigger_id: str):
+        print("########### can_continue")
+        print(Process.queue)
+        print(trigger_id)
+        print(trigger_id in Process.queue)
         if can := (trigger_id in Process.queue):
             Process.queue.remove(trigger_id)
         return not can
 
     @staticmethod
     def has_to_stop(trigger_id: str):
+        print("########### has_to_stop")
+        print(Process.queue)
+        print(trigger_id)
+        print(trigger_id in Process.queue)
         if trigger_id in Process.queue:
             Process.queue.remove(trigger_id)
             raise Process.Stopped()