diff --git a/Sources/pyOpenRPA/Orchestrator/Orchestrator.py b/Sources/pyOpenRPA/Orchestrator/Orchestrator.py index e2c461a2..e4fc5e7a 100644 --- a/Sources/pyOpenRPA/Orchestrator/Orchestrator.py +++ b/Sources/pyOpenRPA/Orchestrator/Orchestrator.py @@ -68,7 +68,7 @@ def AgentOSFileBinaryDataBytesCreate(inGSettings, inHostNameStr, inUserStr, inFi # Send binary file to Agent (base64 string) def AgentOSFileBinaryDataBase64StrCreate(inGSettings, inHostNameStr, inUserStr, inFilePathStr, inFileDataBase64Str): - # pyOpenRPA.Agent: Create binary file by the base64 string (safe for JSON transmition) + # pyOpenRPA.Agent: Create binary file by the base64 string (safe for JSON transmission) # def OSFileBinaryDataBase64StrCreate(inFilePathStr, inFileDataBase64Str,inGSettings = None): # Create Activity Item for the agent lActivityItemDict = { diff --git a/Sources/pyOpenRPA/Orchestrator/ServerSettings.py b/Sources/pyOpenRPA/Orchestrator/ServerSettings.py index 6363ace5..e4b52691 100644 --- a/Sources/pyOpenRPA/Orchestrator/ServerSettings.py +++ b/Sources/pyOpenRPA/Orchestrator/ServerSettings.py @@ -243,17 +243,17 @@ def pyOpenRPA_Agent_O2A(inRequest, inGSettings): if lL: lL.debug(f'O2A BEFORE: ConnectionCountInt: {lThisAgentDict["ConnectionCountInt"]};ConnectionFirstQueueItemCountInt {lThisAgentDict["ConnectionFirstQueueItemCountInt"]}') if lThisAgentDict["ConnectionCountInt"] == lThisAgentDict["ConnectionFirstQueueItemCountInt"] + 1: # POP QUEUE ITEM CONDITION ConnectionCountInt == ConnectionFirstQueueItemCountInt + 1 - lQueueItem = lThisAgentDict["ActivityList"].pop(0) + lActivityItem = lThisAgentDict["ActivityList"].pop(0) lThisAgentDict["ConnectionFirstQueueItemCountInt"] = 0 if lL: lL.debug(f"Activity was deleted from the list: {lThisAgentDict['ActivityList']}") else: - lQueueItem = lThisAgentDict["ActivityList"][0] + lActivityItem = lThisAgentDict["ActivityList"][0] lThisAgentDict["ConnectionFirstQueueItemCountInt"] += 1 if lL: lL.debug(f"Activity was !not! deleted from the list: {lThisAgentDict['ActivityList']}") if lL: lL.debug(f'O2A AFTER: ConnectionCountInt: {lThisAgentDict["ConnectionCountInt"]};ConnectionFirstQueueItemCountInt {lThisAgentDict["ConnectionFirstQueueItemCountInt"]}') # Send QUEUE ITEM - if lL: lL.debug(f"Activity item to agent: {lQueueItem}") - inRequest.OpenRPAResponseDict["Body"] = bytes(json.dumps(lQueueItem), "utf8") + if lL: lL.info(f"Activity item to agent Hostname {lInput['HostNameUpperStr']}, User {lInput['UserUpperStr']}. Activity item: {lActivityItem}") + inRequest.OpenRPAResponseDict["Body"] = bytes(json.dumps(lActivityItem), "utf8") lDoLoopBool = False # CLose the connection else: # no queue item - sleep for the next iteration time.sleep(1) diff --git a/changelog.md b/changelog.md index 62febdcb..f5d815f5 100644 --- a/changelog.md +++ b/changelog.md @@ -70,6 +70,7 @@ - - def AgentOSFileBinaryDataBase64StrCreate(inGSettings, inHostNameStr, inUserStr, inFilePathStr, inFileDataBase64Str): # Send binary file to Agent (base64 string) - - def AgentOSFileTextDataStrCreate(inGSettings, inHostNameStr, inUserStr, inFilePathStr, inFileDataStr, inEncodingStr = "utf-8"): # Send text file to Agent (string) - Orc WEB: Create mGlobal.pyOpenRPA.ActivityListExecute({}) to test some activities from the front +- Orc - add log about send activity to agent [1.1.0] After 2 month test prefinal with new improovements (+RobotRDPActive in Orchestrator + Easy ControlPanelTemplate) Beta before 1.1.0 (new way of OpenRPA with improvements. Sorry, but no backward compatibility)/ Backward compatibility will start from 1.0.1