@@ -343,11 +343,11 @@ def process_raw_log_field(self, field: str, field_type: str) -> Optional[str]:
343343
344344 def process_raw_log_field_prefix (self , field : str , source_mapping : SourceMapping ) -> Optional [list ]:
345345 if isinstance (field , list ):
346- list_of_prefix = []
346+ prefix_list = []
347347 for f in field :
348- if prepared_prefix := self .process_raw_log_field_prefix (field = f , source_mapping = source_mapping ):
349- list_of_prefix .extend (prepared_prefix )
350- return list_of_prefix
348+ if _prefix_list := self .process_raw_log_field_prefix (field = f , source_mapping = source_mapping ):
349+ prefix_list .extend (_prefix_list )
350+ return prefix_list
351351 if raw_log_field_type := source_mapping .raw_log_fields .get (field ):
352352 return [self .process_raw_log_field (field = field , field_type = raw_log_field_type )]
353353
@@ -364,9 +364,11 @@ def generate_raw_log_fields(self, fields: list[Field], source_mapping: SourceMap
364364 )
365365 if not mapped_field and self .is_strict_mapping :
366366 raise StrictPlatformException (field_name = field .source_name , platform_name = self .details .name )
367- if field_prefix := self .process_raw_log_field_prefix (field = mapped_field , source_mapping = source_mapping ):
368- defined_raw_log_fields .extend (field_prefix )
369- return "\n " .join (set (defined_raw_log_fields ))
367+ if prefix_list := self .process_raw_log_field_prefix (field = mapped_field , source_mapping = source_mapping ):
368+ for prefix in prefix_list :
369+ if prefix not in defined_raw_log_fields :
370+ defined_raw_log_fields .append (prefix )
371+ return "\n " .join (defined_raw_log_fields )
370372
371373 def _generate_from_tokenized_query_container (self , query_container : TokenizedQueryContainer ) -> str :
372374 queries_map = {}
0 commit comments