diff --git a/flows/platform_order/riin.py b/flows/platform_order/riin.py index 023797c..621e569 100644 --- a/flows/platform_order/riin.py +++ b/flows/platform_order/riin.py @@ -208,4 +208,5 @@ async def riin_platform_sync(): log_msg("===== 完成 =====") if __name__ == "__main__": - riin_platform_sync.serve(name="platform-order-riin", cron="15 * * * *") + # 直跑一次用于本地调试;勿改回 serve():同名 upsert 会覆盖 server 上挂 work pool 的正式 deployment + riin_platform_sync() diff --git a/flows/platform_order/rouhui.py b/flows/platform_order/rouhui.py index 07644c5..dc3b344 100644 --- a/flows/platform_order/rouhui.py +++ b/flows/platform_order/rouhui.py @@ -273,4 +273,5 @@ def rouhui_platform_sync(): log_msg("===== 提取完成 =====") if __name__ == "__main__": - rouhui_platform_sync.serve(name="platform-order-rouhui", cron="*/15 * * * *") \ No newline at end of file + # 直跑一次用于本地调试;勿改回 serve():同名 upsert 会覆盖 server 上挂 work pool 的正式 deployment + rouhui_platform_sync() \ No newline at end of file diff --git a/flows/platform_order/sdspod.py b/flows/platform_order/sdspod.py index 1244088..a46bc90 100644 --- a/flows/platform_order/sdspod.py +++ b/flows/platform_order/sdspod.py @@ -471,4 +471,5 @@ async def sdspod_platform_sync(): if __name__ == "__main__": - sdspod_platform_sync.serve(name="platform-order-sdspod", cron="*/15 * * * *") \ No newline at end of file + # 直跑一次用于本地调试;勿改回 serve():同名 upsert 会覆盖 server 上挂 work pool 的正式 deployment + sdspod_platform_sync() \ No newline at end of file