42 lines
1.1 KiB
Python
42 lines
1.1 KiB
Python
import requests
|
|
|
|
from core.execution.lifecyclemanager import registerLifecycle
|
|
|
|
def filterMode(mode):
|
|
if mode in ("continuous", "oneshot", "stop"):
|
|
state = mode
|
|
return state
|
|
else: raise ValueError(f"Unsupported lifecycle mode: {mode}")
|
|
|
|
def buildState(module, mode, lifecycles):
|
|
state = filterMode(mode)
|
|
|
|
registryvalue = state
|
|
registryname = "mode"
|
|
|
|
if state != "stop":
|
|
lifecycles = registerLifecycle(module, lifecycles, registryname, registryvalue)
|
|
|
|
elif state == "stop":
|
|
if not module.name in lifecycles:
|
|
|
|
print(f"No registered lifecycle: {module.name}")
|
|
|
|
return None
|
|
|
|
elif "mode" in lifecycles[module.name] != "stop":
|
|
lifecycles = registerLifecycle(module, lifecycles, registryname, registryvalue)
|
|
|
|
print(f"Stopping lifecycle: {module.name}")
|
|
|
|
#elif mode == "oneshot":
|
|
#registryvalue = {"mode": "oneshot"}
|
|
#lifecycles = registerLifecycle(module, lifecycles, registryname, registryvalue)
|
|
|
|
# else:
|
|
#raise ValueError(f"Unsupported lifecycle mode: {mode}")
|
|
|
|
#state = registryvalue
|
|
|
|
return state, lifecycles
|