Stopped returning outputs on buildMonitor
This commit is contained in:
@@ -5,8 +5,7 @@ from core.execution.monitor import buildMonitor
|
|||||||
from core.execution.recursive import buildRecursive
|
from core.execution.recursive import buildRecursive
|
||||||
|
|
||||||
def executeContract(module, outputs, process):
|
def executeContract(module, outputs, process):
|
||||||
#print("DEBUGGING")
|
|
||||||
#print(module.name)
|
|
||||||
if module.kind == "operation":
|
if module.kind == "operation":
|
||||||
|
|
||||||
responses = buildOperation(module, outputs)
|
responses = buildOperation(module, outputs)
|
||||||
@@ -20,7 +19,7 @@ def executeContract(module, outputs, process):
|
|||||||
return outputs, response
|
return outputs, response
|
||||||
|
|
||||||
elif module.kind == "monitor":
|
elif module.kind == "monitor":
|
||||||
outputs, response= buildMonitor(module, outputs)
|
response = buildMonitor(module, outputs)
|
||||||
|
|
||||||
return outputs, response
|
return outputs, response
|
||||||
|
|
||||||
|
|||||||
@@ -6,7 +6,6 @@ from core.execution.operation import buildOperation
|
|||||||
from core.apirequest import executeRequest
|
from core.apirequest import executeRequest
|
||||||
from core.runtime.resolver import resolveItem
|
from core.runtime.resolver import resolveItem
|
||||||
from core.runtime.applyconditions import applyConditions
|
from core.runtime.applyconditions import applyConditions
|
||||||
#from plugins.rmass.actions import login, refresh_tokens
|
|
||||||
from core.runtime import buildOutput
|
from core.runtime import buildOutput
|
||||||
from core.runtime.savedata import loadSave
|
from core.runtime.savedata import loadSave
|
||||||
|
|
||||||
@@ -19,7 +18,7 @@ def buildMonitor(monitor, outputs):
|
|||||||
response, outputs = executeRequest(monitor, outputs, resolved)
|
response, outputs = executeRequest(monitor, outputs, resolved)
|
||||||
|
|
||||||
if response is None:
|
if response is None:
|
||||||
return outputs, None
|
return None
|
||||||
|
|
||||||
responsedata = response.json()
|
responsedata = response.json()
|
||||||
|
|
||||||
@@ -39,4 +38,4 @@ def buildMonitor(monitor, outputs):
|
|||||||
responses = buildOperation(module, outputs)
|
responses = buildOperation(module, outputs)
|
||||||
response = responses
|
response = responses
|
||||||
|
|
||||||
return outputs, response
|
return response
|
||||||
+1
-1
@@ -7,6 +7,6 @@ definition = rmassmonitor
|
|||||||
outputs = {}
|
outputs = {}
|
||||||
resolved = {}
|
resolved = {}
|
||||||
while True:
|
while True:
|
||||||
outputs = buildMonitor(definition, outputs)
|
response = buildMonitor(definition, outputs)
|
||||||
|
|
||||||
time.sleep(definition.refreshrate)
|
time.sleep(definition.refreshrate)
|
||||||
Reference in New Issue
Block a user