fix: reconcile cloud runtime drift

Co-Authored-By: Codex <noreply@openai.com>

Author: Pigbibi

.github/workflows/sync-cloud-run-env.yml

@@ -957,6 +957,18 @@ jobs:
             gcloud "${gcloud_args[@]}"
           done
 
+      - name: Reconcile Cloud Run traffic
+        if: steps.config.outputs.env_sync_enabled == 'true'
+        env:
+          SYNC_PLAN_JSON: ${{ steps.strategy_requirements.outputs.sync_plan_json }}
+        run: |
+          set -euo pipefail
+          python3 scripts/reconcile_cloud_runtime.py \
+            --platform=ibkr \
+            --project="${GCP_PROJECT_ID}" \
+            --region="${CLOUD_RUN_REGION}" \
+            --ensure-latest-traffic
+
       - name: Verify strategy plugin mounts
         if: steps.config.outputs.env_sync_enabled == 'true'
         env:
@@ -1149,32 +1161,12 @@ jobs:
               --quiet
           fi
 
-          for update in "${scheduler_updates[@]}"; do
-            IFS=$'\t' read -r cloud_run_service _market_timezone _main_time <<< "${update}"
-            legacy_candidates=()
-            if [[ "${cloud_run_service}" == *-service ]]; then
-              legacy_candidates+=("${cloud_run_service%-service}-probe-scheduler")
-              legacy_candidates+=("${cloud_run_service%-service}-precheck-scheduler")
-            fi
-            legacy_candidates+=("${cloud_run_service}-probe-scheduler")
-            legacy_candidates+=("${cloud_run_service}-precheck-scheduler")
-            account_suffix="${cloud_run_service#interactive-brokers-quant-live-}"
-            account_suffix="${account_suffix%-service}"
-            if [[ "${account_suffix}" == u* ]]; then
-              legacy_candidates+=("ibkr-${account_suffix}-backup-execution")
-            fi
-            for legacy_job in "${legacy_candidates[@]}"; do
-              if gcloud scheduler jobs describe "${legacy_job}" \
-                --project="${GCP_PROJECT_ID}" \
-                --location="${scheduler_location}" >/dev/null 2>&1; then
-                echo "Deleting legacy Cloud Scheduler job ${legacy_job}; monitor dispatcher now owns probe/precheck."
-                gcloud scheduler jobs delete "${legacy_job}" \
-                  --project="${GCP_PROJECT_ID}" \
-                  --location="${scheduler_location}" \
-                  --quiet
-              fi
-            done
-          done
+          python3 scripts/reconcile_cloud_runtime.py \
+            --platform=ibkr \
+            --project="${GCP_PROJECT_ID}" \
+            --region="${CLOUD_RUN_REGION}" \
+            --scheduler-location="${scheduler_location}" \
+            --delete-legacy-schedulers
 
       - name: Prune old Cloud Run revisions
         if: steps.config.outputs.enabled == 'true'