|
|
@ -3,7 +3,10 @@ from . import O2A, A2O # Data flow Orchestrator To Agent
|
|
|
|
from . import Processor # Processor Queue
|
|
|
|
from . import Processor # Processor Queue
|
|
|
|
from ..Tools import Usage
|
|
|
|
from ..Tools import Usage
|
|
|
|
from ..Tools import License
|
|
|
|
from ..Tools import License
|
|
|
|
from subprocess import CREATE_NEW_CONSOLE # Flag to create new process in another CMD
|
|
|
|
from pyOpenRPA.Tools import CrossOS
|
|
|
|
|
|
|
|
if CrossOS.IS_WINDOWS_BOOL: from subprocess import CREATE_NEW_CONSOLE # Flag to create new process in another CMD
|
|
|
|
|
|
|
|
if CrossOS.IS_LINUX_BOOL: pass
|
|
|
|
|
|
|
|
|
|
|
|
import os
|
|
|
|
import os
|
|
|
|
|
|
|
|
|
|
|
|
gSettings = None
|
|
|
|
gSettings = None
|
|
|
@ -142,8 +145,11 @@ def OSCMD(inCMDStr, inRunAsyncBool=True, inGSettings = None, inSendOutputToOrche
|
|
|
|
if inCaptureBool == True:
|
|
|
|
if inCaptureBool == True:
|
|
|
|
lCMDProcess = subprocess.Popen(f'cmd /c {inCMDStr}', stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
|
|
|
|
lCMDProcess = subprocess.Popen(f'cmd /c {inCMDStr}', stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
lCMDProcess = subprocess.Popen(f'cmd /c {inCMDStr}', stdout=None, stderr=None,
|
|
|
|
if CrossOS.IS_WINDOWS_BOOL:
|
|
|
|
creationflags=CREATE_NEW_CONSOLE)
|
|
|
|
lCMDProcess = subprocess.Popen(f'cmd /c {inCMDStr}', stdout=None, stderr=None,
|
|
|
|
|
|
|
|
creationflags=CREATE_NEW_CONSOLE)
|
|
|
|
|
|
|
|
if CrossOS.IS_LINUX_BOOL:
|
|
|
|
|
|
|
|
lCMDProcess = subprocess.Popen(f'cmd /c {inCMDStr}', stdout=None, stderr=None)
|
|
|
|
lListenBool = True
|
|
|
|
lListenBool = True
|
|
|
|
lMessageStr = f"{lOSCMDKeyStr}: # # # # AGENT CMD Process has been STARTED # # # # "
|
|
|
|
lMessageStr = f"{lOSCMDKeyStr}: # # # # AGENT CMD Process has been STARTED # # # # "
|
|
|
|
if lL: lL.info(lMessageStr)
|
|
|
|
if lL: lL.info(lMessageStr)
|
|
|
|