@@ -197,6 +197,7 @@ class PlatformQueryRender(QueryRender):
197
197
not_token = "not"
198
198
199
199
group_token = "(%s)"
200
+ query_parts_delimiter = " "
200
201
201
202
field_value_map = BaseQueryFieldValue (or_token = or_token )
202
203
@@ -284,6 +285,10 @@ def wrap_query_with_meta_info(self, meta_info: MetaInfoContainer, query: str) ->
284
285
def _finalize_search_query (query : str ) -> str :
285
286
return query
286
287
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
+
287
292
def finalize_query (
288
293
self ,
289
294
prefix : str ,
@@ -295,8 +300,7 @@ def finalize_query(
295
300
* args , # noqa: ARG002
296
301
** kwargs , # noqa: ARG002
297
302
) -> 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 )
300
304
query = self .wrap_query_with_meta_info (meta_info = meta_info , query = query )
301
305
if not_supported_functions :
302
306
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
383
387
defined_raw_log_fields = self .generate_raw_log_fields (
384
388
fields = query_container .meta_info .query_fields , source_mapping = source_mapping
385
389
)
386
- prefix += f"\n { defined_raw_log_fields } \n "
390
+ prefix += f"\n { defined_raw_log_fields } "
387
391
result = self .generate_query (tokens = query_container .tokens , source_mapping = source_mapping )
388
392
except StrictPlatformException as err :
389
393
errors .append (err )
0 commit comments