diff --git a/inbound_verify/runtime.py b/inbound_verify/runtime.py index 70a35b4..264b147 100644 --- a/inbound_verify/runtime.py +++ b/inbound_verify/runtime.py @@ -544,10 +544,10 @@ def _persist_to_db(site, kind): except Exception as e: print(f">> [warn] 入库模块不可用: {e}") return - if not store.ingest_enabled(): - print(">> [入库] 已关闭 (auto_ingest=false),跳过") - return try: + if not store.ingest_enabled(): # 移入 try:config.yaml 缺失/损坏时也不外抛 + print(">> [入库] 已关闭 (auto_ingest=false),跳过") + return count = store.ingest_task(site, kind) state_store.set_ingest_state(site, kind, ok=True, count=count) print(f">> [入库] {site}/{kind} 成功,{count} 条")