diff --git a/app/Controllers/EmployeeServiceController.php b/app/Controllers/EmployeeServiceController.php
index ed5c0a4b..92bad796 100644
--- a/app/Controllers/EmployeeServiceController.php
+++ b/app/Controllers/EmployeeServiceController.php
@@ -17,6 +17,7 @@ use App\Models\FileModel;
 use App\Models\EmpEndorsementModel;
 
 use App\Controllers\Jobs ;
+use App\Controllers\JobWorker ;
 
 use PhpOffice\PhpSpreadsheet\Spreadsheet;
 use Kint\Kint;
@@ -266,8 +267,9 @@ class EmployeeServiceController extends AdminController
                 {
                     //proceed next data level validation in JOB queue
                      $job_details  = new Jobs();
-                     
                      $r = Jobs::addJob(['job_name' => 'excelFileDataValidation','payload' => ['file_id' => $file_id]]);
+                     $jobWorker = new JobWorker();
+                     JobWorker::processJob($r);
                 }       
         return $result;
 
@@ -438,6 +440,8 @@ class EmployeeServiceController extends AdminController
                              $job_details  = new Jobs();
                              
                              $r = Jobs::addJob(['job_name' => 'employeesOnboardPreprocess','payload' => ['file_id' => $file_id]]);
+                             $jobWorker = new JobWorker();
+                             JobWorker::processJob($r);
                         }
                 return $result;
         
diff --git a/app/Controllers/JobWorker.php b/app/Controllers/JobWorker.php
index 964d365a..4499d36b 100644
--- a/app/Controllers/JobWorker.php
+++ b/app/Controllers/JobWorker.php
@@ -27,6 +27,14 @@ class JobWorker extends AdminController
         // }
     }
 
+    public static function streamOutput($data)
+    {
+          ob_implicit_flush(true);
+          // try { ob_end_flush(); } catch(Exception $e) { echo $e->getMessage(); }
+         echo $data;
+         flush();
+    }
+
     public static function  processJobs(array $jobdata = [])
     {
         // echo 'listen';//die();
@@ -49,6 +57,7 @@ class JobWorker extends AdminController
                 //sleep(1);
 
                 SELF::processjob(['id' => $job->id,'uuid' => $job->uuid]);
+                usleep( 500000 );
             }
         }
     }
@@ -86,8 +95,15 @@ class JobWorker extends AdminController
         {
             $job = $job[0];
 
-            echo "\nProcessing job id - " . $job->id . "\n";
-            echo "Job name - " . $job->name . "\n";
+           
+
+            // echo "\nProcessing job id - " . $job->id . "\n";
+            SELF::streamOutput("\nProcessing job id - " . $job->id . "\n");
+            // sleep(5);
+            // echo "Job name - " . $job->name . "\n";
+            SELF::streamOutput("Job name - " . $job->name . "\n");
+            // sleep(5);
+
             // print_r(SELF::$event_class_mapping);
             // echo array_key_exists($job->name,SELF::$event_class_mapping) ? 'mapped' : 'notmapped';
             // die();
@@ -173,7 +189,8 @@ class JobWorker extends AdminController
             ]);
 
            // echo "Job $job->id  $job_status. Response - $response \n";
-            echo "Job $job->id  $job_status \n";
+            // echo "Job $job->id  $job_status \n";
+            SELF::streamOutput("Job $job->id  $job_status \n");
             return true;
         }
         else