修改为保留90天内数据

ad/pai_flow_operator.py

@@ -521,7 +521,7 @@ def update_online_flow():
             try:
                 name = node['name']
                 if name in ('样本shuffle',):
-                    date_begin = '20250605' if name == '样本shuffle' else get_previous_days_date(10)
+                    date_begin = get_previous_days_date(90) if name == '样本shuffle' else get_previous_days_date(10)
                     properties = node['properties']
                     for property in properties:
                         if property['name'] == 'sql':

ad/pai_flow_operator_v2.py

@@ -521,7 +521,7 @@ def update_online_flow():
             try:
                 name = node['name']
                 if name in ('样本shuffle',):
-                    date_begin = '20250605' if name == '样本shuffle' else get_previous_days_date(10)
+                    date_begin = get_previous_days_date(90) if name == '样本shuffle' else get_previous_days_date(10)
                     properties = node['properties']
                     for property in properties:
                         if property['name'] == 'sql':