druid records ingestion task creation changes

JeraldJF · JeraldJF · commit 44f816d7c6e1 · 2025-09-30T17:39:16.000+05:30
diff --git a/command-service/src/command/druid_command.py b/command-service/src/command/druid_command.py
@@ -47,7 +47,7 @@ def _submit_ingestion_task(self, dataset_id):
             )
             task_submitted = 1
             for record in datasources_records:
-                if record["dataset_type"] == "event" and record["type"] == "druid":
+                if record["type"] == "druid":
                     print(f"Submitting ingestion task for datasource  ...")
                     ingestion_spec = json.dumps(record["ingestion_spec"])
                     response = self.http_service.post(

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ def _submit_ingestion_task(self, dataset_id):`
`47`	`47`	`)`
`48`	`48`	`task_submitted = 1`
`49`	`49`	`for record in datasources_records:`
`50`		`- if record["dataset_type"] == "event" and record["type"] == "druid":`
	`50`	`+ if record["type"] == "druid":`
`51`	`51`	`print(f"Submitting ingestion task for datasource ...")`
`52`	`52`	`ingestion_spec = json.dumps(record["ingestion_spec"])`
`53`	`53`	`response = self.http_service.post(`