Skip to content
This repository was archived by the owner on Nov 7, 2025. It is now read-only.

Commit 357325d

Browse files
author
trzysiek
committed
fixed?
1 parent f9d79e2 commit 357325d

File tree

2 files changed

+13
-2
lines changed

2 files changed

+13
-2
lines changed

platform/frontend_connectors/schema_transformer.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -929,6 +929,11 @@ func (s *SchemaCheckPass) applyTimestampFieldd(ctx context.Context, indexSchema
929929
return model.NewLiteral(msLiteral.Value.Milliseconds())
930930
}
931931

932+
expr := query.SelectCommand.Accept(visitor)
933+
if _, ok := expr.(*model.SelectCommand); ok {
934+
query.SelectCommand = *expr.(*model.SelectCommand)
935+
}
936+
932937
return query, nil
933938
}
934939

@@ -1292,8 +1297,8 @@ func (s *SchemaCheckPass) Transform(ctx context.Context, queries []*model.Query)
12921297

12931298
queries[k] = query
12941299

1295-
pp.Println("KK 1", query.SelectCommand)
1296-
fmt.Println("KK 2", model.AsString(query.SelectCommand))
1300+
//pp.Println("KK 1", query.SelectCommand)
1301+
//fmt.Println("KK 2", model.AsString(query.SelectCommand))
12971302
}
12981303
return queries, nil
12991304
}

platform/frontend_connectors/search.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -623,7 +623,13 @@ func (q *QueryRunner) handleSearchCommon(ctx context.Context, indexPattern strin
623623
pushSecondaryInfo(q.debugInfoCollector, id, "", path, bodyAsBytes, queriesBody, responseBody, startTime)
624624
return responseBody, errors.New(string(responseBody))
625625
}
626+
for _, query := range plan.Queries {
627+
fmt.Println("PRE", query.SelectCommand.String())
628+
}
626629
err = q.transformQueries(ctx, plan)
630+
for _, query := range plan.Queries {
631+
fmt.Println("POST", query.SelectCommand.String())
632+
}
627633
if err != nil {
628634
return responseBody, err
629635
}

0 commit comments

Comments
 (0)