From 29ea82821d21ba4eeb9f8960c67f3d79e9e1a43f Mon Sep 17 00:00:00 2001 From: gahusb Date: Fri, 10 Jul 2026 11:26:12 +0900 Subject: [PATCH] =?UTF-8?q?fix(naver-fetch):=20ingest=20=EC=9D=91=EB=8B=B5?= =?UTF-8?q?=20=ED=95=84=EB=93=9C=20matched=E2=86=92queued=20(BE=20async=20?= =?UTF-8?q?8e28ce9=20=EC=A0=95=ED=95=A9)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- services/naver-fetch/fetch_worker.py | 5 +++-- services/naver-fetch/tests/test_fetch_worker.py | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/services/naver-fetch/fetch_worker.py b/services/naver-fetch/fetch_worker.py index 0041562..f6c08bf 100644 --- a/services/naver-fetch/fetch_worker.py +++ b/services/naver-fetch/fetch_worker.py @@ -77,8 +77,9 @@ async def run_cycle(nas, naver, state, settings) -> None: continue try: r = await nas.post_ingest(fetched_at, [{"dong": dong, "articles": articles}]) - logger.info("ingest dong=%s received=%s new=%s matched=%s", - dong, r.get("received"), r.get("new"), r.get("matched")) + # BE ingest async화(main 8e28ce9): 응답 {received,new,queued} (matched는 백그라운드라 제거됨) + logger.info("ingest dong=%s received=%s new=%s queued=%s", + dong, r.get("received"), r.get("new"), r.get("queued")) state.listings_pushed += len(articles) except Exception: logger.exception("listings-ingest 실패 dong=%s", dong) diff --git a/services/naver-fetch/tests/test_fetch_worker.py b/services/naver-fetch/tests/test_fetch_worker.py index e4a9b50..e381263 100644 --- a/services/naver-fetch/tests/test_fetch_worker.py +++ b/services/naver-fetch/tests/test_fetch_worker.py @@ -31,7 +31,7 @@ class _FakeNAS: async def post_ingest(self, fetched_at, batches): self.ingests.append({"fetched_at": fetched_at, "batches": batches}) n = sum(len(b["articles"]) for b in batches) - return {"received": n, "new": n, "matched": 0} + return {"received": n, "new": n, "queued": True} class _FakeNaver: