jherve 1 рік тому
батько
коміт
68d3748fed
1 змінених файлів з 0 додано та 3 видалено
  1. 0 3
      src/media_observer/test.py

+ 0 - 3
src/media_observer/test.py

@@ -172,9 +172,6 @@ async def main():
         async with InternetArchiveClient.create() as ia:
             worker = SnapshotWorker(15, snap_queue, storage, ia)
             async with asyncio.TaskGroup() as tg:
-                for i in range(0, 2):
-                    w = Worker(i)
-                    tasks.append(tg.create_task(w.loop()))
                 for i in range(0, 2):
                     qw = QueueWorker(i, queue=queues[i])
                     tasks.append(tg.create_task(qw.loop()))