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()