|
@@ -232,7 +232,7 @@ def fetch_data(label_datetime: datetime, feature_start_datetime: datetime, view_
|
|
|
def xgb_multi_dt_data(t_1_label_dt: datetime):
|
|
|
with concurrent.futures.ThreadPoolExecutor(3) as executor:
|
|
|
logger.info(f"VOV模型特征数据处理:t_1_label_future.label_datetime: {t_1_label_dt.strftime('%Y%m%d')}")
|
|
|
- t_1_label_future = executor.submit(fetch_data, t_1_label_dt, t_1_label_dt - timedelta(2), t_1_label_dt)
|
|
|
+ t_1_label_future = executor.submit(fetch_data, t_1_label_dt, t_1_label_dt - timedelta(1), t_1_label_dt)
|
|
|
|
|
|
t_2_label_dt = t_1_label_dt - timedelta(1)
|
|
|
logger.info(f"VOV模型特征数据处理:t_2_label_future.label_datetime: {t_2_label_dt.strftime('%Y%m%d')}")
|