diff --git a/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/QueueTriggerCS/__init__.py b/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/QueueTriggerCS/__init__.py index 79aea85c3d..5be28a93d3 100644 --- a/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/QueueTriggerCS/__init__.py +++ b/Solutions/CrowdStrike Falcon 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/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/Sample8.zip b/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/Sample8.zip index 5e08dcfb73..8dc0e51440 100644 Binary files a/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/Sample8.zip and b/Solutions/CrowdStrike Falcon Endpoint Protection/Data Connectors/CrowdstrikeReplicatorCLv2/Sample8.zip differ