Merge branch 'main' into schema-validator

Sanketika-Obsrv · Aug 27, 2024 · df9d38d · df9d38d
2 parents 0fa749e + 65865e6
commit df9d38d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/data-products/src/main/scala/org/sunbird/obsrv/dataproducts/MasterDataProcessorIndexer.scala b/data-products/src/main/scala/org/sunbird/obsrv/dataproducts/MasterDataProcessorIndexer.scala
@@ -90,7 +90,7 @@ object MasterDataProcessorIndexer {
   }
 
   def fetchDatasource(dataset: Dataset): DataSource = {
-    val datasources: List[DataSource] = DatasetRegistry.getDatasources(dataset.id).get
+    val datasources: List[DataSource] = DatasetRegistry.getDatasources(dataset.id).get.filter(ds => ds.`type`.toLowerCase() == "druid")
     if (datasources.isEmpty) {
       throw new ObsrvException(ErrorConstants.ERR_DATASOURCE_NOT_FOUND)
     }