add logs

enjin · Mar 7, 2024 · bd29867 · bd29867
1 parent a72dbc8
commit bd29867
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/job-handlers/compute-traits.ts b/src/job-handlers/compute-traits.ts
@@ -67,11 +67,14 @@ export default async (job: Queue.Job<JobData>, done: Queue.DoneCallback) => {
     })
 
     if (!traitTypeMap.size) {
+        job.log(`No traits found for collection ${collectionId}`)
         done()
 
         return
     }
 
+    job.log(`Found ${traitTypeMap.size} trait types`)
+
     const traitsToSave: Trait[] = []
 
     traitTypeMap.forEach((traitValueMap, traitType) => {
@@ -88,6 +91,8 @@ export default async (job: Queue.Job<JobData>, done: Queue.DoneCallback) => {
         })
     })
 
+    job.log(`Saving ${traitsToSave.length} traits`)
+
     await em.save(Trait, traitsToSave as any, { chunk: 1000 })
     const traitTokensToSave: TraitToken[] = []
 
@@ -105,6 +110,7 @@ export default async (job: Queue.Job<JobData>, done: Queue.DoneCallback) => {
     })
 
     if (traitTokensToSave.length) {
+        job.log(`Saving ${traitsToSave.length} token traits`)
         await em.save(TraitToken, traitTokensToSave as any, { chunk: 1000 })
     }
 

diff --git a/src/jobs/compute-traits.ts b/src/jobs/compute-traits.ts
@@ -4,7 +4,7 @@ import { redisConfig } from './common'
 export type JobData = { collectionId: string }
 
 export const traitsQueue = new Queue<JobData>('traitsQueue', {
-    defaultJobOptions: { delay: 2000, attempts: 2, removeOnComplete: true },
+    defaultJobOptions: { delay: 2000, attempts: 2, removeOnComplete: 100 },
     redis: redisConfig,
     settings: {
         maxStalledCount: 3,