Refine
This commit is contained in:
@@ -3,6 +3,7 @@ import globals
|
|||||||
from datetime import datetime, timedelta, timezone
|
from datetime import datetime, timedelta, timezone
|
||||||
import schedule
|
import schedule
|
||||||
import time
|
import time
|
||||||
|
import shutil
|
||||||
from influxdb_client import InfluxDBClient, BucketsApi, WriteApi, OrganizationsApi, Point, QueryApi
|
from influxdb_client import InfluxDBClient, BucketsApi, WriteApi, OrganizationsApi, Point, QueryApi
|
||||||
import simulation
|
import simulation
|
||||||
import influxdb_info
|
import influxdb_info
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import json
|
|||||||
import pytz
|
import pytz
|
||||||
import requests
|
import requests
|
||||||
import time
|
import time
|
||||||
|
import shutil
|
||||||
from epanet.epanet import Output
|
from epanet.epanet import Output
|
||||||
from typing import Optional, Tuple
|
from typing import Optional, Tuple
|
||||||
import influxdb_api
|
import influxdb_api
|
||||||
@@ -1009,9 +1010,11 @@ def run_simulation(name: str, simulation_type: str, modify_pattern_start_time: s
|
|||||||
|
|
||||||
close_project(name_c)
|
close_project(name_c)
|
||||||
|
|
||||||
time.sleep(30) # wait 30 seconds
|
time.sleep(5) # wait 50 seconds
|
||||||
|
|
||||||
output = Output(f"./temp/{name_c}.db.out")
|
tmp_file = './temp/simulation.result.out'
|
||||||
|
shutil.copy(f'./temp/{name_c}.db.out', tmp_file)
|
||||||
|
output = Output(tmp_file)
|
||||||
node_result = output.node_results()
|
node_result = output.node_results()
|
||||||
link_result = output.link_results()
|
link_result = output.link_results()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user