Update worker.py

worker.py

@@ -14,25 +14,19 @@ async def start_worker(worker_id: int):
                 await asyncio.sleep(2)
                 continue
 
-            # Pop a word from the right side of the queue
             word = await r.rpop("frag:queue")
             if not word:
                 await asyncio.sleep(2)
                 continue
 
-            # Get a random verified proxy
             proxy = await db.get_random_proxy()
-
-            # Execute stealth scrape
             status = await scraper.check_fragment(word, proxy_url=proxy)
             
-            # If the proxy timed out or crashed, put the word back on the queue and rest
             if status == "ERROR":
                 await r.lpush("frag:queue", word)
                 await asyncio.sleep(1.5)
                 continue
 
-            # Success! Log it and continue
             if status:
                 await db.mark_done(word, status)
 
@@ -41,12 +35,10 @@ async def start_worker(worker_id: int):
             traceback.print_exc()
             await asyncio.sleep(2)
 
-# --- RENAMED TO MATCH YOUR main.py ---
 async def run_worker():
     print("🚀 Sniper Engine Starting...")
     concurrency = await db.get_concurrency()
     
-    # Spawn tasks individually so a single worker crash doesn't kill the pool
     tasks = []
     for i in range(concurrency):
         task = asyncio.create_task(start_worker(i))