dekun/qihuo
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

fix: start_recommend_worker 参数名 quote_fn 与调用方一致

Browse Source 
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
dekun
2026-06-24 12:57:55 +08:00
parent aea9aca472
commit 9d4aea60f0
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
recommend_stream.py
+2 -2
View File
@@ -53,7 +53,7 @@ def start_recommend_worker(
*, *,
db_path: str, db_path: str,
get_capital_fn: Callable, get_capital_fn: Callable,
price_fn: Callable[[str], Optional[dict]], quote_fn: Callable[[str], Optional[dict]],
init_tables_fn: Callable | None = None, init_tables_fn: Callable | None = None,
interval: int = REFRESH_INTERVAL_SEC, interval: int = REFRESH_INTERVAL_SEC,
) -> None: ) -> None:
@@ -67,7 +67,7 @@ def start_recommend_worker(
if init_tables_fn: if init_tables_fn:
init_tables_fn(conn) init_tables_fn(conn)
capital = float(get_capital_fn(conn) or 0) 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) payload = load_recommend_cache(conn)
finally: finally:
conn.close() conn.close()