Skip to content

Commit b454385

Browse files
committed
fixing review comments
1 parent bbbc155 commit b454385

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

python-sdk/exospherehost/statemanager.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
import os
22
import aiohttp
33
import asyncio
4+
import time
45

56
from typing import Any
67
from pydantic import BaseModel
7-
from datetime import datetime, timedelta
88

99

1010
class TriggerState(BaseModel):
@@ -207,16 +207,16 @@ async def upsert_graph(self, graph_name: str, graph_nodes: list[dict[str, Any]],
207207
}
208208
async with aiohttp.ClientSession() as session:
209209
async with session.put(endpoint, json=body, headers=headers) as response: # type: ignore
210-
if response.status != 201:
210+
if response.status not in [200, 201]:
211211
raise Exception(f"Failed to upsert graph: {response.status} {await response.text()}")
212212
graph = await response.json()
213213

214214
validation_state = graph["validation_status"]
215215

216-
start_time = datetime.now()
216+
start_time = time.monotonic()
217217
while validation_state == "PENDING":
218-
if datetime.now() - start_time > timedelta(seconds=validation_timeout):
219-
raise Exception(f"Graph validation timed out after {validation_timeout} seconds")
218+
if time.monotonic() - start_time > validation_timeout:
219+
raise Exception(f"Graph validation check timed out after {validation_timeout} seconds")
220220
await asyncio.sleep(polling_interval)
221221
graph = await self.get_graph(graph_name)
222222
validation_state = graph["validation_status"]

0 commit comments

Comments
 (0)