From 9d4aea60f0771499acc0045a54066ed44c0baf74 Mon Sep 17 00:00:00 2001 From: dekun Date: Wed, 24 Jun 2026 12:57:55 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20start=5Frecommend=5Fworker=20=E5=8F=82?= =?UTF-8?q?=E6=95=B0=E5=90=8D=20quote=5Ffn=20=E4=B8=8E=E8=B0=83=E7=94=A8?= =?UTF-8?q?=E6=96=B9=E4=B8=80=E8=87=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Cursor --- recommend_stream.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/recommend_stream.py b/recommend_stream.py index 56a517b..85ba827 100644 --- a/recommend_stream.py +++ b/recommend_stream.py @@ -53,7 +53,7 @@ def start_recommend_worker( *, db_path: str, get_capital_fn: Callable, - price_fn: Callable[[str], Optional[dict]], + quote_fn: Callable[[str], Optional[dict]], init_tables_fn: Callable | None = None, interval: int = REFRESH_INTERVAL_SEC, ) -> None: @@ -67,7 +67,7 @@ def start_recommend_worker( if init_tables_fn: init_tables_fn(conn) capital = float(get_capital_fn(conn) or 0) - refresh_recommend_cache(conn, capital, price_fn) + refresh_recommend_cache(conn, capital, quote_fn) payload = load_recommend_cache(conn) finally: conn.close()