feat: prevent Writer Framework version mismatch local/cloud

src/writer/deploy.py

@@ -291,9 +291,8 @@ def upload_package(deploy_url, tar, token, env, verbose=False, sleep_interval=5)
         time.sleep(sleep_interval)
         start_time = end_time
 
-    _check_version_integrity(deploy_url)
-
     if status == "COMPLETED":
+        _check_version_integrity(url, token)
         print("Deployment successful")
         print(f"URL: {url}")
         sys.exit(0)
@@ -323,16 +322,26 @@ def unauthorized_error():
     sys.exit(1)
 
 
-def _check_version_integrity(app_url: str):
+def _check_version_integrity(app_url: str, token: str):
     """
     Check if the writer version in the deployment package is newer than the writer version running on the server.
 
+    >>> _check_version_integrity("https://xxxxxxxxxxxxxxxx.ai.writer.build", "xxxxxxxxxxxxxxxxxxxxxxxxxx")
     """
-    with requests.get(f"{app_url}/_meta") as resp:
-        data = resp.json()
-        if "writer_version_dev" not in data or "writer_version_run" not in data:
-            return
-
-        if Version(data["writer_version_dev"]) > Version(data["writer_version_run"]):
-            print(f"[WARNING] The writer version in the deployment package ({data['writer_version_dev']}) is newer than the writer version running on the server ({data['writer_version_run']}).")
-            return
+    try:
+        with requests.get(
+            f"{app_url}/_meta",
+            headers={
+                "Authorization": f"Bearer {token}",
+            },
+        ) as resp:
+            data = resp.json()
+            if "writer_version_dev" not in data or "writer_version_run" not in data:
+                return
+
+            if Version(data["writer_version_dev"]) > Version(data["writer_version_run"]):
+                print(f"[WARNING] The writer version in the deployment package ({data['writer_version_dev']}) is newer than the writer version running on the server ({data['writer_version_run']}).")
+                return
+    except requests.exceptions.RequestException as e:
+        print("Ignore local / cloud version integrity check")
+        logging.debug(f"Error checking version integrity {e}", exc_info=e)