|
|
@@ -28,7 +28,7 @@ def run(ymd):
|
|
|
|
|
|
def run_order_history():
|
|
|
"""当order表跑了历史的数据，要从这历史数据的最早时间跑此任务流"""
|
|
|
- for i in du.getDateLists('2019-11-12',du.get_n_days(0)):
|
|
|
+ for i in du.getDateLists('2020-11-01',du.get_n_days(0)):
|
|
|
print(i)
|
|
|
ods_order(i)
|
|
|
order_sync_ck(i)
|
|
|
@@ -39,7 +39,7 @@ def run_order_history():
|
|
|
|
|
|
def run_cost_history():
|
|
|
"cost 重跑后，跑此任务流"
|
|
|
- for i in du.getDateLists('2019-03-18',du.get_n_days(0)):
|
|
|
+ for i in du.getDateLists('2020-11-01',du.get_n_days(0)):
|
|
|
print(i)
|
|
|
dw_daily_channel_cost(i)
|
|
|
dw_order_channel_cost_sync_ck(i)
|
|
|
@@ -55,8 +55,8 @@ def main():
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
- main()
|
|
|
-
|
|
|
+ # main()
|
|
|
+ run_order_history()
|
|
|
|
|
|
|
|
|
|
