|
|
@ -796,15 +796,6 @@ from .. import __version__ # Get version from the package
|
|
|
|
def Orchestrator(inGSettings):
|
|
|
|
def Orchestrator(inGSettings):
|
|
|
|
lL = inGSettings["Logger"]
|
|
|
|
lL = inGSettings["Logger"]
|
|
|
|
|
|
|
|
|
|
|
|
# Append Orchestrator def to ProcessorDictAlias
|
|
|
|
|
|
|
|
lModule = sys.modules[__name__]
|
|
|
|
|
|
|
|
lModuleDefList = dir(lModule)
|
|
|
|
|
|
|
|
for lItemDefNameStr in lModuleDefList:
|
|
|
|
|
|
|
|
# Dont append alias for defs Orchestrator and ___deprecated_orchestrator_start__
|
|
|
|
|
|
|
|
if lItemDefNameStr not in ["Orchestrator", "___deprecated_orchestrator_start__"]:
|
|
|
|
|
|
|
|
lItemDef = getattr(lModule,lItemDefNameStr)
|
|
|
|
|
|
|
|
if callable(lItemDef): inGSettings["ProcessorDict"]["AliasDefDict"][lItemDefNameStr]=lItemDef
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#mGlobalDict = Settings.Settings(sys.argv[1])
|
|
|
|
#mGlobalDict = Settings.Settings(sys.argv[1])
|
|
|
|
gSettingsDict = inGSettings # Alias for old name in alg
|
|
|
|
gSettingsDict = inGSettings # Alias for old name in alg
|
|
|
|
inGSettings["VersionStr"] = __version__
|
|
|
|
inGSettings["VersionStr"] = __version__
|
|
|
@ -855,6 +846,15 @@ def Orchestrator(inGSettings):
|
|
|
|
# Turn on backward compatibility
|
|
|
|
# Turn on backward compatibility
|
|
|
|
BackwardCompatibility.Update(inGSettings= gSettingsDict)
|
|
|
|
BackwardCompatibility.Update(inGSettings= gSettingsDict)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# Append Orchestrator def to ProcessorDictAlias
|
|
|
|
|
|
|
|
lModule = sys.modules[__name__]
|
|
|
|
|
|
|
|
lModuleDefList = dir(lModule)
|
|
|
|
|
|
|
|
for lItemDefNameStr in lModuleDefList:
|
|
|
|
|
|
|
|
# Dont append alias for defs Orchestrator and ___deprecated_orchestrator_start__
|
|
|
|
|
|
|
|
if lItemDefNameStr not in ["Orchestrator", "___deprecated_orchestrator_start__"]:
|
|
|
|
|
|
|
|
lItemDef = getattr(lModule,lItemDefNameStr)
|
|
|
|
|
|
|
|
if callable(lItemDef): inGSettings["ProcessorDict"]["AliasDefDict"][lItemDefNameStr]=lItemDef
|
|
|
|
|
|
|
|
|
|
|
|
#Инициализация сервера
|
|
|
|
#Инициализация сервера
|
|
|
|
lThreadServer = Server.RobotDaemonServer("ServerThread", gSettingsDict)
|
|
|
|
lThreadServer = Server.RobotDaemonServer("ServerThread", gSettingsDict)
|
|
|
|
lThreadServer.start()
|
|
|
|
lThreadServer.start()
|
|
|
|