Added sleep

Azure · Jul 17, 2023 · dde8497 · dde8497
1 parent ba5d2d2
commit dde8497
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/... Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/QueueTriggerCS/__init__.py b/... Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/QueueTriggerCS/__init__.py
@@ -84,7 +84,6 @@ async def main(msg: func.QueueMessage) -> None:
                         await process_file_secondary_CLv2(bucket, link, client, session)
                     else:
                         await process_file_primary_CLv2(bucket, link, client, session, eventsSchemaMappingDict, requiredFieldsMappingDict)
-                    logging.info("Successfully executed {} Bucket.".format(link)) 
                 except Exception as e:
                     logging.error('Error while processing bucket. Error: {}'.format(link, str(e)))
                     raise e
@@ -174,6 +173,7 @@ async def process_file_primary_CLv2(bucket, s3_path, client, session, eventsSche
             async for decompressed_chunk in AsyncGZIPDecompressedStream(response["Body"]):
                 s += decompressed_chunk.decode(errors='ignore')
                 lines = re.split(r'{0}'.format(LINE_SEPARATOR), s)
+                await session.sleep(0)
                 for n, line in enumerate(lines):
                     if n < len(lines) - 1:
                         if line:

diff --git a/...wdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/Sample8.zip b/...wdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/Sample8.zip