fixes to avoid jl timeout, avoid skipping funding escrow and adjust cron expression (#1949)

Author: portuu3

packages/apps/job-launcher/server/src/modules/cron-job/cron-job.service.ts

@@ -84,7 +84,10 @@ export class CronJobService {
     const cronJob = await this.startCronJob(CronJobType.CreateEscrow);
 
     try {
-      const jobEntities = await this.jobRepository.findByStatus(JobStatus.PAID);
+      const jobEntities = await this.jobRepository.findByStatus(
+        JobStatus.PAID,
+        3,
+      );
       for (const jobEntity of jobEntities) {
         try {
           await this.jobService.createEscrow(jobEntity);
@@ -116,6 +119,7 @@ export class CronJobService {
     try {
       const jobEntities = await this.jobRepository.findByStatus(
         JobStatus.CREATED,
+        3,
       );
 
       for (const jobEntity of jobEntities) {
@@ -149,6 +153,7 @@ export class CronJobService {
     try {
       const jobEntities = await this.jobRepository.findByStatus(
         JobStatus.SET_UP,
+        3,
       );
 
       for (const jobEntity of jobEntities) {
@@ -182,6 +187,7 @@ export class CronJobService {
     try {
       const jobEntities = await this.jobRepository.findByStatus(
         JobStatus.TO_CANCEL,
+        3,
       );
 
       for (const jobEntity of jobEntities) {

packages/apps/job-launcher/server/src/modules/job/job.repository.ts

@@ -40,7 +40,10 @@ export class JobRepository extends BaseRepository<JobEntity> {
     });
   }
 
-  public async findByStatus(status: JobStatus): Promise<JobEntity[]> {
+  public async findByStatus(
+    status: JobStatus,
+    take?: number,
+  ): Promise<JobEntity[]> {
     return this.find({
       where: {
         status: status,
@@ -51,6 +54,7 @@ export class JobRepository extends BaseRepository<JobEntity> {
         createdAt: SortDirection.DESC,
         waitUntil: SortDirection.ASC,
       },
+      ...(take && { take }),
     });
   }
 

packages/apps/job-launcher/server/vercel.json

@@ -55,23 +55,23 @@
   "crons": [
     {
       "path": "/cron/escrow/create",
-      "schedule": "*/5 * * * *"
+      "schedule": "*/2 * * * *"
     },
     {
       "path": "/cron/escrow/setup",
-      "schedule": "*/5 * * * *"
+      "schedule": "1-59/2 * * * *"
     },
     {
       "path": "/cron/escrow/fund",
-      "schedule": "*/5 * * * *"
+      "schedule": "*/2 * * * *"
     },
     {
       "path": "/cron/escrow/cancel",
       "schedule": "*/5 * * * *"
     },
     {
       "path": "/cron/webhook/process",
-      "schedule": "*/5 * * * *"
+      "schedule": "*/3 * * * *"
     }
   ],
   "headers": [

packages/sdk/typescript/human-protocol-sdk/src/escrow.ts

@@ -486,7 +486,7 @@ export class EscrowClient extends BaseEthersClient {
       );
       await (
         await tokenContract.transfer(escrowAddress, amount, txOptions)
-      ).wait;
+      ).wait();
 
       return;
     } catch (e) {