2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 09:32:21 +00:00

Correct missing parameter in Geist

Geist support was missing a variable in the refactor.
This commit is contained in:
Jarrod Johnson 2023-04-19 10:20:34 -04:00
parent 55a796af82
commit 55da173b27

View File

@ -178,7 +178,7 @@ def read_sensors(element, node, configmanager):
else:
yield msg.SensorReadings(readings, name=node)
def get_outlet(node, configmanager):
def get_outlet(node, configmanager, element):
gc = GeistClient(node, configmanager)
state = gc.get_outlet(element[-1])
return msg.PowerState(node=node, state=state)
@ -193,7 +193,7 @@ def retrieve(nodes, element, configmanager, inputdata):
if 'outlets' in element:
gp = greenpool.GreenPile(pdupool)
for node in nodes:
gp.spawn(get_outlet, node, configmanager)
gp.spawn(get_outlet, node, configmanager, element)
for res in gp:
yield res