OPEN_RPA_PUBLIC
/
ORPA-pyOpenRPA
2
0
Fork 1
Code Issues 2 Pull Requests Packages Projects Releases Wiki Activity

АГТ: Минорная правка, убрать сообщение об ошибке, если от орка пришел None

Browse Source
dev-fastapi
Иван Маслов 2 years ago
parent 89087dc7fe
commit 4e868f6898
1 changed files with 15 additions and 14 deletions
Show Stats Download Patch File Download Diff File

29
Sources/pyOpenRPA/Agent/O2A.py
Unescape View File

@ -42,20 +42,21 @@ def O2A_Loop(inGSettings):
lBodyLenInt = len(lRequestBody) lBodyLenInt = len(lRequestBody)
if lBodyLenInt != 0: # CHeck if not empty result when close the connection from orch if lBodyLenInt != 0: # CHeck if not empty result when close the connection from orch
lQueueList = lResponse.json() # Try to get JSON lQueueList = lResponse.json() # Try to get JSON
for lQueueItem in lQueueList: if lQueueList != None:
# Append QUEUE item in ProcessorDict > ActivityList for lQueueItem in lQueueList:
lActivityLastGUIDStr = lQueueItem["GUIDStr"] # Append QUEUE item in ProcessorDict > ActivityList
# Check if ActivityItem ["ThreadBool"] = False > go sync mode in processor queue; Else: New thread lActivityLastGUIDStr = lQueueItem["GUIDStr"]
if lQueueItem.get("ThreadBool",False) == False: # Check if ActivityItem ["ThreadBool"] = False > go sync mode in processor queue; Else: New thread
inGSettings["ProcessorDict"]["ActivityList"].append(lQueueItem) if lQueueItem.get("ThreadBool",False) == False:
else: inGSettings["ProcessorDict"]["ActivityList"].append(lQueueItem)
Processor.ProcessorRunAsync(inGSettings=inGSettings,inActivityList=[lQueueItem]) else:
# Log full version if bytes size is less than limit . else short Processor.ProcessorRunAsync(inGSettings=inGSettings,inActivityList=[lQueueItem])
lAgentLimitLogSizeBytesInt = 500 # Log full version if bytes size is less than limit . else short
if lBodyLenInt <= lAgentLimitLogSizeBytesInt: lAgentLimitLogSizeBytesInt = 500
if lL: lL.info(f"Словарь ActivityItem, полученный от оркестратора: {lQueueItem}") if lBodyLenInt <= lAgentLimitLogSizeBytesInt:
else: if lL: lL.info(f"Словарь ActivityItem, полученный от оркестратора: {lQueueItem}")
if lL: lL.info(f"Словарь ActivityItem, полученный от оркестратора: содержимое свернуто из-за большого размера ({lBodyLenInt} байт") else:
if lL: lL.info(f"Словарь ActivityItem, полученный от оркестратора: содержимое свернуто из-за большого размера ({lBodyLenInt} байт")
else: else:
if lL: lL.debug(f"Поступил пустой ответ от оркестратора - цикл попытается обновить соединение между оркестратором и агентом"); if lL: lL.debug(f"Поступил пустой ответ от оркестратора - цикл попытается обновить соединение между оркестратором и агентом");
except requests.exceptions.ConnectionError as e: except requests.exceptions.ConnectionError as e:

Write Preview
Loading…
Cancel
Save