|
@@ -150,7 +150,7 @@ def get_train_data_list(date_begin):
|
|
|
return date_list
|
|
return date_list
|
|
|
|
|
|
|
|
|
|
|
|
|
-def update_data_date_range(old_str, date_begin='20250320'):
|
|
|
|
|
|
|
+def update_data_date_range(old_str, date_begin='20250605'):
|
|
|
date_list = get_train_data_list(date_begin)
|
|
date_list = get_train_data_list(date_begin)
|
|
|
train_list = ["'" + item + "'" for item in date_list]
|
|
train_list = ["'" + item + "'" for item in date_list]
|
|
|
result = ','.join(train_list)
|
|
result = ','.join(train_list)
|
|
@@ -520,7 +520,7 @@ def update_online_flow():
|
|
|
try:
|
|
try:
|
|
|
name = node['name']
|
|
name = node['name']
|
|
|
if name in ('样本shuffle', '评估样本重组'):
|
|
if name in ('样本shuffle', '评估样本重组'):
|
|
|
- date_begin = '20250320' if name == '样本shuffle' else get_previous_days_date(10)
|
|
|
|
|
|
|
+ date_begin = '20250605' if name == '样本shuffle' else get_previous_days_date(10)
|
|
|
properties = node['properties']
|
|
properties = node['properties']
|
|
|
for property in properties:
|
|
for property in properties:
|
|
|
if property['name'] == 'sql':
|
|
if property['name'] == 'sql':
|
xueyiming