eletrotupi / tcc/ commit / 80d91bc

api: ditch other failed insight jobs

Pedro Lucas Porcellis porcellis@eletrotupi.com 1 month ago 80d91bc2ac14c41ba7e7ed6b4640d9d958a3b41f
Parents: 507c97f
2 file(s) changed
  • api/src/services/mood.service.ts +3 -0
  • api/src/services/sleepRecord.service.ts +2 -0
api/src/services/mood.service.ts
1 1 
import { prisma } from "@app/lib/prisma";
2 2 
import { Mood } from "@prisma/client";
3 3 
import { rollingPeriod } from "@app/lib/queue/processors/insights/utils";
4 4 
import { InsightJobName } from "@app/lib/queue/types";
5 5 
import { getQueue } from "@app/lib/queue";
▸ 106 unchanged lines
112 112 
      name: InsightJobName.MoodTrend,
113 113 
      data: payload,
114 114 
      opts: {
115 115 
        jobId: `mood-trend-${userId}-${new Date().toDateString()}`,
116 116 
        removeOnComplete: true,
117 + 
        removeOnFail: true,
117 118 
      },
118 119 
    },
119 120 
    {
120 121 
      name: InsightJobName.EnergySleep,
121 122 
      data: payload,
122 123 
      opts: {
123 124 
        jobId: `energy-sleep-${userId}-${new Date().toDateString()}`,
124 125 
        removeOnComplete: true,
126 + 
        removeOnFail: true,
125 127 
      },
126 128 
    },
127 129 
    {
128 130 
      name: InsightJobName.DailyEnergy,
129 131 
      data: payload,
130 132 
      opts: {
131 133 
        jobId: `daily-energy-${userId}-${new Date().toDateString()}`,
132 134 
        removeOnComplete: true,
135 + 
        removeOnFail: true,
133 136 
      },
134 137 
    },
135 138 
  ]);
136 139 
};
api/src/services/sleepRecord.service.ts
1 1 
import { prisma } from '@app/lib/prisma';
2 2 
import { SleepRecord } from '@prisma/client';
3 3
4 4 
import { CreateSleepRecordInput } from '@app/schemas';
5 5 
import { rollingPeriod } from "@app/lib/queue/processors/insights/utils";
▸ 86 unchanged lines
92 92 
      name: InsightJobName.EnergySleep,
93 93 
      data: payload,
94 94 
      opts: {
95 95 
        jobId: `energy-sleep-${userId}-${new Date().toDateString()}`,
96 96 
        removeOnComplete: true,
97 + 
        removeOnFail: true,
97 98 
      }
98 99 
    },
99 100 
    {
100 101 
      name: InsightJobName.DailySleep,
101 102 
      data: {
▸ 2 unchanged lines
104 105 
        periodEnd: new Date()
105 106 
      },
106 107 
      opts: {
107 108 
        jobId: `daily-sleep-${userId}-${new Date().toDateString()}`,
108 109 
        removeOnComplete: true,
110 + 
        removeOnFail: true,
109 111 
      },
110 112 
    },
111 113 
  ]);
112 114 
}