.

server/jobs/syncHeytripJobs.js

@@ -57,7 +57,7 @@ const AidsState = () => {
         }
       } else {
         console.log('pre job running! cancelNext[AidsState]');
-        jobAS.cancelNext();
+        jobAS.cancelNext(true);
       }
     });
   });
@@ -77,16 +77,19 @@ const newHotelDetails = () => {
 
       const isRunning = job1.pendingInvocations[0]?.job?.running == 1;
       if (!isRunning) {
+        try {
           const res = await heytripService.newHotels('1');
-
           // job1.cancel(); // debug: 0
           if (res.next !== true) {
             job1.cancel(res.restart);
             console.log('job completed! canceled job[newHotelDetails]!');
           }
+        } catch (error) {
+          job1.cancelNext(true);
+        }
       } else {
         console.log('pre job running! cancelNext[newHotelDetails]');
-        job1.cancelNext();
+        job1.cancelNext(true);
       }
     });
   });
@@ -105,16 +108,19 @@ const hotelLgcDetails = () => {
 
       const isRunning = job2.pendingInvocations[0]?.job?.running == 1;
       if (!isRunning) {
+        try {
           const res = await heytripService.newHotelsLgc('1');
-
           // job2.cancel(); // debug: 0
           if (res.next !== true) {
             job2.cancel(res.restart);
             console.log('job completed! canceled job[hotelLgcDetails]!');
           }
+        } catch (error) {
+          job2.cancelNext(true);
+        }
       } else {
         console.log('pre job running! cancelNext[hotelLgcDetails]');
-        job2.cancelNext();
+        job2.cancelNext(true);
       }
     });
   });
@@ -132,6 +138,7 @@ const chinaHotelDetails = () => {
       console.log('-------------------------syncing heytrip[chinaHotelDetails], get china accommodation details.-------------------------');
       const isRunning = job3.pendingInvocations[0]?.job?.running == 1;
       if (!isRunning) {
+        try {
           const res = await heytripService.chinaHotelsLgc2('2');
           // job3.cancel(); // debug: 0
           if (res.next !== true) {
@@ -139,9 +146,12 @@ const chinaHotelDetails = () => {
             console.log('job completed! canceled job[chinaHotelDetails]!');
             // job3.reschedule('0 0 0 * * *');
           }
+        } catch (error) {
+          job3.cancelNext(true);
+        }
       } else {
         console.log('pre job running! cancelNext[chinaHotelDetails]');
-        job3.cancelNext();
+        job3.cancelNext(true);
       }
     });
   });