@@ -124,12 +124,13 @@ def generate_prefix(self, log_source_signature: Optional[LogSourceSignature], fu
124124return ""
125125
126126def generate_output (self ,fields :list [Field ],unmapped_fields :list [str ],source_mapping :SourceMapping )-> str :
127- extra_fields = [
128- field .source_name
129- if field .source_name in unmapped_fields
130- else source_mapping .fields_mapping .get_platform_field_name (generic_field_name = field .source_name )
131- for field in fields
132- ]
127+ extra_fields = []
128+ for field in fields :
129+ if field .source_name in unmapped_fields :
130+ extra_fields .append (field .source_name )
131+ elif generic_field_name := field .get_generic_field_name (source_mapping .source_id ):
132+ if extra_field := source_mapping .fields_mapping .get_platform_field_name (generic_field_name ):
133+ extra_fields .append (extra_field )
133134extra_fields = [f"{ field .replace ('.' ,'_' )} =%{ field } " for field in extra_fields ]
134135return f"shell in a container (container_name=%container.name{ ' ' .join (extra_fields )} )"
135136