dekun/crypto_monitor
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(hub): correct _mark_meta_sync NameError in archive seed

Browse Source 
seed_symbol_archive and sync_symbol_klines_incremental called undefined _mark_meta.

Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
dekun
2026-06-07 23:05:25 +08:00
parent 3052607280
commit 92ff945d72
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hub_symbol_archive_lib.py
+2 -2
View File
@@ -723,7 +723,7 @@ def seed_symbol_archive(
bars = fetch_remote_5m_range(remote_fetch, sym, start_ms, end_ms)
n = upsert_bars_5m(ex_k, sym, bars, db_path=db_path)
now = _now_ms()
_mark_meta(ex_k, sym, kline_ms=now, seed_complete=True, db_path=db_path)
_mark_meta_sync(ex_k, sym, kline_ms=now, seed_complete=True, db_path=db_path)
return {"ok": True, "seed_bars": n, "start_ms": start_ms, "end_ms": end_ms}
@@ -756,7 +756,7 @@ def sync_symbol_klines_incremental(
bars = fetch_remote_5m_range(remote_fetch, sym, start_ms, end_ms)
n = upsert_bars_5m(ex_k, sym, bars, db_path=db_path)
now = _now_ms()
_mark_meta(ex_k, sym, kline_ms=now, db_path=db_path)
_mark_meta_sync(ex_k, sym, kline_ms=now, db_path=db_path)
return {"ok": True, "appended": n, "start_ms": start_ms, "end_ms": end_ms}