Skip to content
Snippets Groups Projects
Commit 41544498 authored by Simon Oehrl's avatar Simon Oehrl
Browse files

Update node ips before every query

parent 1796e032
Branches
No related tags found
No related merge requests found
Pipeline #163397 passed
......@@ -25,18 +25,18 @@ def ConnectToDatabase(postgres_username, postgres_password):
def main():
# Wait for simulation nodes to post to database
time.sleep(5)
# get simulation nodes
con = ConnectToDatabase('postgres', 'postgres')
cur = con.cursor()
# NEST
cur.execute("SELECT address FROM nest_simulation_node")
nodes.nest_simulation_nodes = [i[0] for i in cur.fetchall()]
# Arbor
cur.execute("SELECT address FROM nest_simulation_node")
nodes.arbor_simulation_nodes = [i[0] for i in cur.fetchall()]
con.close()
time.sleep(0.1)
# # get simulation nodes
# con = ConnectToDatabase('postgres', 'postgres')
# cur = con.cursor()
# # NEST
# cur.execute("SELECT address FROM nest_simulation_node")
# nodes.nest_simulation_nodes = [i[0] for i in cur.fetchall()]
# # Arbor
# cur.execute("SELECT address FROM nest_simulation_node")
# nodes.arbor_simulation_nodes = [i[0] for i in cur.fetchall()]
# con.close()
# run acces_node
......
......@@ -234,8 +234,14 @@ def nest_get_simulation_time_info(): # noqa: E501
:rtype: SimulationTimeInfo
"""
con = connect_to_database()
cur = con.cursor()
cur.execute("SELECT address FROM nest_simulation_node")
nodes.nest_simulation_nodes = [i[0] for i in cur.fetchall()]
con.close()
current_time = float('inf')
print("Hello")
for node in nodes.nest_simulation_nodes:
response = requests.get(
node+'/current_simulation_time').json()
......@@ -264,6 +270,13 @@ def nest_get_spikes(_from=None, to=None, gids=None, offset=None, limit=None): #
:rtype: Spikes
"""
con = connect_to_database()
cur = con.cursor()
cur.execute("SELECT address FROM nest_simulation_node")
nodes.nest_simulation_nodes = [i[0] for i in cur.fetchall()]
con.close()
spikes = Spikes([], [])
for node in nodes.nest_simulation_nodes:
response = requests.get(
......@@ -307,6 +320,12 @@ def nest_get_spikes_by_population(population_id, _from=None, to=None, offset=Non
:rtype: Spikes
"""
con = connect_to_database()
cur = con.cursor()
cur.execute("SELECT address FROM nest_simulation_node")
nodes.nest_simulation_nodes = [i[0] for i in cur.fetchall()]
con.close()
spikes = Spikes([], [])
for node in nodes.nest_simulation_nodes:
response = requests.get(
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment