@@ -197,6 +197,7 @@ class PlatformQueryRender(QueryRender):
197197 not_token = "not"
198198
199199 group_token = "(%s)"
200+ query_parts_delimiter = " "
200201
201202 field_value_map = BaseQueryFieldValue (or_token = or_token )
202203
@@ -284,6 +285,10 @@ def wrap_query_with_meta_info(self, meta_info: MetaInfoContainer, query: str) ->
284285 def _finalize_search_query (query : str ) -> str :
285286 return query
286287
288+ def _join_query_parts (self , prefix : str , query : str , functions : str ) -> str :
289+ parts = filter (lambda s : bool (s ), map (str .strip , [prefix , self ._finalize_search_query (query ), functions ]))
290+ return self .query_parts_delimiter .join (parts )
291+
287292 def finalize_query (
288293 self ,
289294 prefix : str ,
@@ -295,8 +300,7 @@ def finalize_query(
295300 * args , # noqa: ARG002
296301 ** kwargs , # noqa: ARG002
297302 ) -> str :
298- parts = filter (lambda s : bool (s ), map (str .strip , [prefix , self ._finalize_search_query (query ), functions ]))
299- query = " " .join (parts )
303+ query = self ._join_query_parts (prefix , query , functions )
300304 query = self .wrap_query_with_meta_info (meta_info = meta_info , query = query )
301305 if not_supported_functions :
302306 rendered_not_supported = self .render_not_supported_functions (not_supported_functions )
@@ -383,7 +387,7 @@ def _generate_from_tokenized_query_container(self, query_container: TokenizedQue
383387 defined_raw_log_fields = self .generate_raw_log_fields (
384388 fields = query_container .meta_info .query_fields , source_mapping = source_mapping
385389 )
386- prefix += f"\n { defined_raw_log_fields } \n "
390+ prefix += f"\n { defined_raw_log_fields } "
387391 result = self .generate_query (tokens = query_container .tokens , source_mapping = source_mapping )
388392 except StrictPlatformException as err :
389393 errors .append (err )
0 commit comments