diff --git a/src/main/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportAction.java b/src/main/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportAction.java
index a4706834..afdeb868 100644
--- a/src/main/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportAction.java
+++ b/src/main/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportAction.java
@@ -26,6 +26,7 @@
 import org.opensearch.geospatial.ip2geo.jobscheduler.Datasource;
 import org.opensearch.ingest.IngestService;
 import org.opensearch.tasks.Task;
+import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.TransportService;
 
 /**
@@ -39,6 +40,7 @@ public class DeleteDatasourceTransportAction extends HandledTransportAction<Dele
     private final DatasourceFacade datasourceFacade;
     private final GeoIpDataFacade geoIpDataFacade;
     private final Ip2GeoProcessorFacade ip2GeoProcessorFacade;
+    private final ThreadPool threadPool;
 
     /**
      * Constructor
@@ -56,7 +58,8 @@ public DeleteDatasourceTransportAction(
         final IngestService ingestService,
         final DatasourceFacade datasourceFacade,
         final GeoIpDataFacade geoIpDataFacade,
-        final Ip2GeoProcessorFacade ip2GeoProcessorFacade
+        final Ip2GeoProcessorFacade ip2GeoProcessorFacade,
+        final ThreadPool threadPool
     ) {
         super(DeleteDatasourceAction.NAME, transportService, actionFilters, DeleteDatasourceRequest::new);
         this.lockService = lockService;
@@ -64,6 +67,7 @@ public DeleteDatasourceTransportAction(
         this.datasourceFacade = datasourceFacade;
         this.geoIpDataFacade = geoIpDataFacade;
         this.ip2GeoProcessorFacade = ip2GeoProcessorFacade;
+        this.threadPool = threadPool;
     }
 
     /**
@@ -83,9 +87,16 @@ protected void doExecute(final Task task, final DeleteDatasourceRequest request,
                 return;
             }
             try {
-                deleteDatasource(request.getName());
-                lockService.releaseLock(lock);
-                listener.onResponse(new AcknowledgedResponse(true));
+                threadPool.generic().submit(() -> {
+                    try {
+                        deleteDatasource(request.getName());
+                        lockService.releaseLock(lock);
+                        listener.onResponse(new AcknowledgedResponse(true));
+                    } catch (Exception e) {
+                        lockService.releaseLock(lock);
+                        listener.onFailure(e);
+                    }
+                });
             } catch (Exception e) {
                 lockService.releaseLock(lock);
                 listener.onFailure(e);
diff --git a/src/main/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportAction.java b/src/main/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportAction.java
index ffdb349d..07132851 100644
--- a/src/main/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportAction.java
+++ b/src/main/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportAction.java
@@ -31,6 +31,7 @@
 import org.opensearch.geospatial.ip2geo.jobscheduler.DatasourceUpdateService;
 import org.opensearch.jobscheduler.spi.schedule.IntervalSchedule;
 import org.opensearch.tasks.Task;
+import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.TransportService;
 
 /**
@@ -42,6 +43,7 @@ public class UpdateDatasourceTransportAction extends HandledTransportAction<Upda
     private final Ip2GeoLockService lockService;
     private final DatasourceFacade datasourceFacade;
     private final DatasourceUpdateService datasourceUpdateService;
+    private final ThreadPool threadPool;
 
     /**
      * Constructor
@@ -58,12 +60,14 @@ public UpdateDatasourceTransportAction(
         final ActionFilters actionFilters,
         final Ip2GeoLockService lockService,
         final DatasourceFacade datasourceFacade,
-        final DatasourceUpdateService datasourceUpdateService
+        final DatasourceUpdateService datasourceUpdateService,
+        final ThreadPool threadPool
     ) {
         super(UpdateDatasourceAction.NAME, transportService, actionFilters, UpdateDatasourceRequest::new);
         this.lockService = lockService;
         this.datasourceUpdateService = datasourceUpdateService;
         this.datasourceFacade = datasourceFacade;
+        this.threadPool = threadPool;
     }
 
     /**
@@ -82,16 +86,22 @@ protected void doExecute(final Task task, final UpdateDatasourceRequest request,
                 );
                 return;
             }
-
             try {
-                Datasource datasource = datasourceFacade.getDatasource(request.getName());
-                if (datasource == null) {
-                    throw new ResourceNotFoundException("no such datasource exist");
-                }
-                validate(request, datasource);
-                updateIfChanged(request, datasource);
-                lockService.releaseLock(lock);
-                listener.onResponse(new AcknowledgedResponse(true));
+                threadPool.generic().submit(() -> {
+                    try {
+                        Datasource datasource = datasourceFacade.getDatasource(request.getName());
+                        if (datasource == null) {
+                            throw new ResourceNotFoundException("no such datasource exist");
+                        }
+                        validate(request, datasource);
+                        updateIfChanged(request, datasource);
+                        lockService.releaseLock(lock);
+                        listener.onResponse(new AcknowledgedResponse(true));
+                    } catch (Exception e) {
+                        lockService.releaseLock(lock);
+                        listener.onFailure(e);
+                    }
+                });
             } catch (Exception e) {
                 lockService.releaseLock(lock);
                 listener.onFailure(e);
diff --git a/src/test/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportActionTests.java b/src/test/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportActionTests.java
index fa2afef8..ce5c91d4 100644
--- a/src/test/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportActionTests.java
+++ b/src/test/java/org/opensearch/geospatial/ip2geo/action/DeleteDatasourceTransportActionTests.java
@@ -48,7 +48,8 @@ public void init() {
             ingestService,
             datasourceFacade,
             geoIpDataFacade,
-            ip2GeoProcessorFacade
+            ip2GeoProcessorFacade,
+            threadPool
         );
     }
 
diff --git a/src/test/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportActionTests.java b/src/test/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportActionTests.java
index 3df610e8..32272f62 100644
--- a/src/test/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportActionTests.java
+++ b/src/test/java/org/opensearch/geospatial/ip2geo/action/UpdateDatasourceTransportActionTests.java
@@ -45,7 +45,8 @@ public void init() {
             actionFilters,
             ip2GeoLockService,
             datasourceFacade,
-            datasourceUpdateService
+            datasourceUpdateService,
+            threadPool
         );
     }