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: