diff --git a/pipeline_bidding/bid_flow.py b/pipeline_bidding/bid_flow.py index 44b6a52..672949b 100644 --- a/pipeline_bidding/bid_flow.py +++ b/pipeline_bidding/bid_flow.py @@ -336,6 +336,7 @@ def start_poller(): async def _bid_poller(app): async def _loop(): db, dbname = get_db() + POLLER_STATE["last_error"] = "" while True: try: async def _once(): @@ -363,6 +364,11 @@ def start_poller(): logger.warning("bid_poller error/timeout: %s", str(e)[:200]) await asyncio.sleep(POLL_INTERVAL) + try: + from appPublic.log import debug as _dbg0 + _dbg0("bid_flow poller handler invoked, creating loop task") + except Exception: + pass asyncio.create_task(_loop()) try: from appPublic.log import debug as _dbg diff --git a/pipeline_bidding/init.py b/pipeline_bidding/init.py index 1a50309..604d2e2 100644 --- a/pipeline_bidding/init.py +++ b/pipeline_bidding/init.py @@ -46,7 +46,13 @@ def load_pipeline_bidding(): if mode in ("all", "worker"): try: from .bid_flow import start_poller - start_poller() + r = start_poller() + try: + from appPublic.log import debug as _dbg + _dbg("[pipeline_bidding] poller register result: %s (PIPELINE_MODE=%s)" % (r, mode)) + except Exception: + pass + logger.info("[pipeline_bidding] poller register: %s (mode=%s)", r, mode) except Exception as e: logger.warning("[pipeline_bidding] poller 启动失败: %s", str(e)[:200]) ok = False