logging

farcasterxyz · Dec 11, 2024 · b3c5a17 · b3c5a17
1 parent 09be229
commit b3c5a17
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/packages/shuttle/src/example-app/worker.ts b/packages/shuttle/src/example-app/worker.ts
@@ -9,6 +9,7 @@ export function getWorker(app: App, redis: Redis | Cluster, log: pino.Logger, co
   const worker = new Worker(
     QUEUE_NAME,
     async (job: Job) => {
+      log.info({ job }, "Starting job");
       if (job.name === "reconcile") {
         const start = Date.now();
         const fids = job.data.fids as number[];

diff --git a/packages/shuttle/src/shuttle/messageReconciliation.ts b/packages/shuttle/src/shuttle/messageReconciliation.ts
@@ -176,7 +176,6 @@ export class MessageReconciliation {
     for await (const messages of fn.call(this, fid, MAX_PAGE_SIZE, startTimestamp, stopTimestamp)) {
       yield messages as Message[];
     }
-    this.log.info({ type, fid }, "[reconciliation] Done all hub messages of type");
   }
 
   private async doCallWithFailover(