diff --git a/app/Controllers/EmployeeController.php b/app/Controllers/EmployeeController.php
index 812e6f28..3c1d1940 100755
--- a/app/Controllers/EmployeeController.php
+++ b/app/Controllers/EmployeeController.php
@@ -4305,7 +4305,7 @@ class EmployeeController extends AdminController
             }
 
         // this will match tpa api data with emp/emp policy table and update ref in tpa api data once
-        $this->reconTpaApiDataWithEmployeepolicies($file_id);
+        $this->reconTpaApiDataWithEmployeepolicies(['file_id' => $file_id]);
         } else {
             // echo 'else';die;
             // Cached mode:
@@ -4449,10 +4449,10 @@ class EmployeeController extends AdminController
                     {
                         sleep(1);
                        //initiate update references b/w tpa_api_data and employess (pk update)
-                        $this->reconTpaApiDataWithEmployeepolicies($file_id);
+                        // $this->reconTpaApiDataWithEmployeepolicies(['file_id' => $file_id]);
                         sleep(1);
                        //initiate deleteion if any
-                        $this->initializeDeletionProcessForTpaApiData($file_id);
+                        // $this->initializeDeletionProcessForTpaApiData(['file_id' => $file_id]);
 
                     }
                     else
@@ -6523,7 +6523,7 @@ class EmployeeController extends AdminController
     public function reconTpaApiDataWithEmployeepolicies($file_id): array
     {
         try {
-            $fileId = (int) $file_id;
+            $fileId = (int) $file_id['file_id'];
             if ($fileId <= 0) {
                 return [
                     'status' => false,
@@ -6716,7 +6716,7 @@ class EmployeeController extends AdminController
     {
         // echo 'DELETION';
         try {
-            $fileId = (int) $file_id;
+            $fileId = (int) $file_id['file_id'];
             if ($fileId <= 0) {
                 return [
                     'status' => false,
diff --git a/app/Controllers/EmployeeServiceController.php b/app/Controllers/EmployeeServiceController.php
index b5d73432..faf98a6a 100755
--- a/app/Controllers/EmployeeServiceController.php
+++ b/app/Controllers/EmployeeServiceController.php
@@ -1754,6 +1754,8 @@ class EmployeeServiceController extends AdminController
 
         if(!empty($batch_file_id)){
             $r = Jobs::addJob(['job_name' => 'updateEmployeeDataFromTpa','payload' => ['file_id' => $file_id, 'batch_file_id' => $batch_file_id]]);
+            $r = Jobs::addJob(['job_name' => 'reconTpaApiDataWithEmployeepolicies','payload' => ['file_id' => $batch_file_id]]);
+            $r = Jobs::addJob(['job_name' => 'initializeDeletionProcessForTpaApiData','payload' => ['file_id' =>  $batch_file_id]]);
             $this->myLogger->logme("error", 'Batch file id {batch_file_id} processed successfully', ['batch_file_id' => $batch_file_id]);
         }
 
diff --git a/app/Controllers/JobWorker.php b/app/Controllers/JobWorker.php
index f6d9f2eb..466cbf82 100755
--- a/app/Controllers/JobWorker.php
+++ b/app/Controllers/JobWorker.php
@@ -278,6 +278,14 @@ class JobWorker extends AdminController
     'updateTpaIdForNotInNhance' => [
         'type' => 'CC', // Handler Category
         'handler' => 'App\Controllers\EmployeeController',
+    ],
+    'initializeDeletionProcessForTpaApiData' => [
+        'type' => 'CC', // Handler Category
+        'handler' => 'App\Controllers\EmployeeController',
+    ],
+    'reconTpaApiDataWithEmployeepolicies' => [
+        'type' => 'CC', // Handler Category
+        'handler' => 'App\Controllers\EmployeeController',
     ]
 ];