From 422b797c658bdc9610970c6cf2d2c0f175408482 Mon Sep 17 00:00:00 2001 From: Christopher Harris Date: Wed, 21 Aug 2024 23:51:34 +0000 Subject: [PATCH] fix windows event log parsing --- ci/scripts/download_kafka.py | 4 ++-- python/morpheus/morpheus/parsers/event_parser.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ci/scripts/download_kafka.py b/ci/scripts/download_kafka.py index d4f60ed86b..85edfbfa47 100644 --- a/ci/scripts/download_kafka.py +++ b/ci/scripts/download_kafka.py @@ -20,8 +20,8 @@ import pytest_kafka from pytest_kafka.install import set_up_kafka -DEFAULT_KAFKA_URL = 'https://downloads.apache.org/kafka/3.5.2/kafka_2.13-3.5.2.tgz' -DEFAULT_KAFKA_TAR_ROOTDIR = 'kafka_2.13-3.5.2/' +DEFAULT_KAFKA_URL = 'https://downloads.apache.org/kafka/3.8.0/kafka_2.13-3.8.0.tgz' +DEFAULT_KAFKA_TAR_ROOTDIR = 'kafka_2.13-3.8.0/' def main(): diff --git a/python/morpheus/morpheus/parsers/event_parser.py b/python/morpheus/morpheus/parsers/event_parser.py index 998232c130..a82785b48a 100644 --- a/python/morpheus/morpheus/parsers/event_parser.py +++ b/python/morpheus/morpheus/parsers/event_parser.py @@ -98,7 +98,7 @@ def parse_raw_event(self, text: cudf.Series, event_regex: typing.Dict[str, any]) # Applies regex pattern for each expected output column to raw data for col in event_specific_columns: regex_pattern = event_regex.get(col) - extracted_gdf = text.str.extract(regex_pattern) + extracted_gdf = text.str.extract(regex_pattern).reset_index() if not extracted_gdf.empty: parsed_gdf[col] = extracted_gdf[0]