Use blpop for redis, and flush logs

Author: sajadbahar

app/worker.py

@@ -11,19 +11,19 @@
 redis_client = redis.StrictRedis(host=REDIS_HOST, port=REDIS_PORT, decode_responses=True)
 
 def process_job(job):
-    print(f"Processing job: {job}")
+    print(f"Processing job: {job}", flush=True)
     # Simulate the time to send a push notification
-    time.sleep(1)
+    time.sleep(20)
 
 def main():
-    print("Worker started...")
+    print("Worker started...", flush=True)
     while True:
-        job = redis_client.lpop(QUEUE_NAME)
+        job = redis_client.blpop(QUEUE_NAME, 100)
         if job:
             process_job(job)
         else:
-            print("No jobs in queue. Waiting...")
+            print("No jobs in queue. Waiting...", flush=True)
             time.sleep(5)
 
 if __name__ == "__main__":
-    main()
+    main()