Submit task for druid records

JeraldJF · JeraldJF · commit beaf2b09d73f · 2025-09-30T16:07:20.000+05:30
diff --git a/command-service/src/command/druid_command.py b/command-service/src/command/druid_command.py
@@ -36,7 +36,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
`@@ -36,7 +36,7 @@ def _submit_ingestion_task(self, dataset_id):`
`36`	`36`	`)`
`37`	`37`	`task_submitted = 1`
`38`	`38`	`for record in datasources_records:`
`39`		`- if record["dataset_type"] == "event" and record["type"] == "druid":`
	`39`	`+ if record["type"] == "druid":`
`40`	`40`	`print(f"Submitting ingestion task for datasource ...")`
`41`	`41`	`ingestion_spec = json.dumps(record["ingestion_spec"])`
`42`	`42`	`response = self.http_service.post(`