소스 검색

Move InternetArchiveClient creation

jherve 1 년 전
부모
커밋
0b711ddb88
1개의 변경된 파일2개의 추가작업 그리고 6개의 파일을 삭제
  1. 2 6
      src/de_quoi_parle_le_monde/snapshots.py

+ 2 - 6
src/de_quoi_parle_le_monde/snapshots.py

@@ -113,11 +113,6 @@ class SnapshotWorker:
         except Exception:
             return
 
-    @staticmethod
-    def create(storage: Storage, session: HttpSession):
-        ia = InternetArchiveClient(session)
-        return SnapshotWorker(storage, ia)
-
 
 async def main():
     http_client = HttpClient()
@@ -127,7 +122,8 @@ async def main():
     jobs = SnapshotJob.create(10, [8, 12, 18, 22])
 
     async with http_client.session() as session:
-        worker = SnapshotWorker.create(storage, session)
+        ia = InternetArchiveClient(session)
+        worker = SnapshotWorker(storage, ia)
         await asyncio.gather(*[worker.run(job) for job in jobs])
     logger.info("Snapshot service exiting")