data streams too

Author: mieciu

quesma/quesma/functionality/resolve/resolve.go

@@ -6,7 +6,6 @@ import (
 	"quesma/elasticsearch"
 	"quesma/quesma/config"
 	"quesma/schema"
-	"slices"
 )
 
 func HandleResolve(pattern string, sr schema.Registry, cfg *config.QuesmaConfiguration) (elasticsearch.Sources, error) {
@@ -52,11 +51,6 @@ func HandleResolve(pattern string, sr schema.Registry, cfg *config.QuesmaConfigu
 }
 
 func combineSourcesFromElasticWithRegistry(sourcesFromElastic *elasticsearch.Sources, schemas map[schema.TableName]schema.Schema, normalizedPattern string) {
-	sourcesFromElastic.DataStreams = slices.DeleteFunc(sourcesFromElastic.DataStreams, func(i elasticsearch.DataStream) bool {
-		_, exists := schemas[schema.TableName(i.Name)]
-		return exists
-	})
-
 	for name, currentSchema := range schemas {
 		indexName := name.AsString()