Merge pull request #11488 from Azure/v-sabiraj-crowdstrikeupdatinglog…

…ging Updated the logic for the warning message
Azure · Nov 26, 2024 · 09b5238 · 09b5238
2 parents 5d25d76 + 0386d04
commit 09b5238
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/...Protection/Data Connectors/CrowdstrikeReplicatorCLv2/CrowdstrikeFalconAPISentinelConn.zip b/...Protection/Data Connectors/CrowdstrikeReplicatorCLv2/CrowdstrikeFalconAPISentinelConn.zip
diff --git a/...s/CrowdstrikeReplicatorCLv2/CrowdstrikeFalconAPISentinelConn/Replicator/main_aws_queue.py b/...s/CrowdstrikeReplicatorCLv2/CrowdstrikeFalconAPISentinelConn/Replicator/main_aws_queue.py
@@ -107,7 +107,7 @@ async def main(mytimer: func.TimerRequest):
                         logging.info("Got message with MessageId {}. Start processing {} files from Bucket: {}. Path prefix: {}. Timestamp: {}.".format(msg["MessageId"], body_obj["fileCount"], body_obj["bucket"], body_obj["pathPrefix"], body_obj["timestamp"]))
 
                         diffFromNow = int(time.time()*1000) - int(body_obj["timestamp"])
-                        if diffFromNow >= 3600:
+                        if diffFromNow >= 3600000:
                             logging.warn("More than 1 hour old records are getting processed now. This indicates requirement for additional function app.")
                         await download_message_files_queue(mainQueueHelper, backlogQueueHelper, msg["MessageId"], body_obj)