Merge pull request #92 from Cloudshelf/logging-trigger

chore: add more logging
Cloudshelf · Dec 30, 2024 · e1abd53 · e1abd53
2 parents 8ef2142 + bd65b18
commit e1abd53
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/src/modules/data-ingestion/product.job.utils.ts b/src/modules/data-ingestion/product.job.utils.ts
@@ -41,8 +41,12 @@ export class ProductJobUtils {
             taskIdentifier: [RequestProductsTask.id],
             tag: searchTags,
         })) {
-            console.log(run);
-            pendingRuns.push({ id: run.id, type: run.tags.includes('type_full') ? 'type_full' : 'type_partial' });
+            const i: { id: string; type: 'type_full' | 'type_partial' } = {
+                id: run.id,
+                type: run.tags.includes('type_full') ? 'type_full' : 'type_partial',
+            };
+            pendingRuns.push(i);
+            console.log(`pushing pending run`, i);
         }
         logs?.info(`Found ${pendingRuns.length} existing jobs...`);
 

diff --git a/src/modules/tools/tools.resolver.ts b/src/modules/tools/tools.resolver.ts
@@ -87,9 +87,17 @@ export class ToolsResolver {
         }
 
         if (partial) {
-            await ProductJobUtils.scheduleTriggerJob(retailer, false, 10, 'forceViaGql');
+            await ProductJobUtils.scheduleTriggerJob(retailer, false, 10, 'forceViaGql', {
+                info: (s, o) => console.info(s, o),
+                warn: (s, o) => console.warn(s, o),
+                error: (s, o) => console.error(s, o),
+            });
         } else {
-            await ProductJobUtils.scheduleTriggerJob(retailer, true, undefined, 'forceViaGql');
+            await ProductJobUtils.scheduleTriggerJob(retailer, true, undefined, 'forceViaGql', {
+                info: (s, o) => console.info(s, o),
+                warn: (s, o) => console.warn(s, o),
+                error: (s, o) => console.error(s, o),
+            });
         }
         return 'Scheduled a sync';
     }