OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refine

Browse Source
This commit is contained in:
DingZQ
2025-01-30 23:15:31 +08:00
parent 5da8fb7c07
commit e3fe2ddf51
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
main.py
View File

@@ -180,7 +180,7 @@ async def fastapi_run_project(network: str) -> str:
# 尝试获取锁（NX=True: 不存在时设置，EX=timeout: 过期时间） # 尝试获取锁（NX=True: 不存在时设置，EX=timeout: 过期时间）
acquired = redis_client.set(lock_key, "locked", nx=True, ex=timeout) acquired = redis_client.set(lock_key, "locked", nx=True, ex=timeout)
logging.log(acquired) logger.info(f"acquired : {acquired}")
if not acquired: if not acquired:
raise HTTPException(status_code=409, detail="is in simulation") raise HTTPException(status_code=409, detail="is in simulation")
@@ -1470,7 +1470,7 @@ async def fastapi_get_network_link_nodes(network: str) -> list[str] | None:
async def fastapi_get_major_pipe_nodes(network: str, diameter: int) -> list[str] | None: async def fastapi_get_major_pipe_nodes(network: str, diameter: int) -> list[str] | None:
start_time = time.time() start_time = time.time()
result = get_major_pipe_nodes(network, diameter) result = get_major_pipe_nodes(network, diameter)
end_time = time.time() end_time = time.time)
logger.info("get_major_pipe_nodes: %s, time: %s", result, end_time - start_time) logger.info("get_major_pipe_nodes: %s, time: %s", result, end_time - start_time)
return result return result