From 57d0c7954f05c5669df4c74027d3e00d9b742125 Mon Sep 17 00:00:00 2001
From: Guofu Li
Date: Wed, 24 Aug 2022 23:36:11 +0800
Subject: [PATCH] bug fixes
---
src/loader/DDBHFTLoader.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/loader/DDBHFTLoader.py b/src/loader/DDBHFTLoader.py
index fe420b8..0a0ba7a 100644
--- a/src/loader/DDBHFTLoader.py
+++ b/src/loader/DDBHFTLoader.py
@@ -390,9 +390,9 @@ class DDBHFTLoader(DDBLoader):
# 这里只把日期值不再`_journal_dt`的记录放入`row_list`
if _journal_dt is not None:
row_list = [row for row in row_list
- if pd.to_datetime(row[1]) not in _journal_dt]
+ if pd.to_datetime(row[1]) not in _journal_dt.index]
print(f"Resume job for {stock_id}, with {len(row_list)} rows left.")
-
+
num_rows = len(row_list)
# 如果行数为0,则说明是空数据,可以直接返回
if num_rows == 0: