my prefect server setup
prefect-metrics.waow.tech
python
orchestration
fix: add error response logging to atlas deploy step
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
+16
-6
+16
-6
flows/atlas.py
+16
-6
flows/atlas.py
···
89
89
json={"manifest": manifest, "branch": "main"},
90
90
timeout=60,
91
91
)
92
-
resp.raise_for_status()
92
+
if not resp.is_success:
93
+
logger.error(f"create deployment failed ({resp.status_code}): {resp.text[:500]}")
94
+
resp.raise_for_status()
93
95
deployment = resp.json()["result"]
94
96
jwt = deployment["jwt"]
95
97
logger.info(f"deployment {deployment['id']} created")
···
102
104
json={"hashes": list(content_by_hash.keys())},
103
105
timeout=30,
104
106
)
105
-
resp.raise_for_status()
107
+
if not resp.is_success:
108
+
logger.error(f"check-missing failed ({resp.status_code}): {resp.text[:500]}")
109
+
resp.raise_for_status()
106
110
missing = set(resp.json())
107
111
logger.info(f"{len(missing)} files to upload ({len(manifest) - len(missing)} cached)")
108
112
···
112
116
for h in missing:
113
117
batch.append((h, ("blob", content_by_hash[h], "application/octet-stream")))
114
118
if len(batch) >= 50:
115
-
httpx.post(
119
+
r = httpx.post(
116
120
f"{CF_API}/pages/assets/upload",
117
121
headers=jwt_headers,
118
122
files=batch,
119
123
timeout=120,
120
-
).raise_for_status()
124
+
)
125
+
if not r.is_success:
126
+
logger.error(f"upload failed ({r.status_code}): {r.text[:500]}")
127
+
r.raise_for_status()
121
128
batch = []
122
129
if batch:
123
-
httpx.post(
130
+
r = httpx.post(
124
131
f"{CF_API}/pages/assets/upload",
125
132
headers=jwt_headers,
126
133
files=batch,
127
134
timeout=120,
128
-
).raise_for_status()
135
+
)
136
+
if not r.is_success:
137
+
logger.error(f"upload failed ({r.status_code}): {r.text[:500]}")
138
+
r.raise_for_status()
129
139
130
140
url = deployment.get("url", "")
131
141
logger.info(f"deployed: {url}")