Added GraphileLogger

matt-aitken · matt-aitken · commit c970e892a700 · 2024-06-05T16:20:19.000+01:00
diff --git a/apps/webapp/app/platform/zodWorker.server.ts b/apps/webapp/app/platform/zodWorker.server.ts
@@ -10,7 +10,12 @@ import type {
   TaskSpec,
   WorkerUtils,
 } from "graphile-worker";
-import { run as graphileRun, makeWorkerUtils, parseCronItems } from "graphile-worker";
+import {
+  run as graphileRun,
+  makeWorkerUtils,
+  parseCronItems,
+  Logger as GraphileLogger,
+} from "graphile-worker";
 import { SpanKind, trace } from "@opentelemetry/api";
 
 import omit from "lodash.omit";
@@ -26,6 +31,12 @@ export interface MessageCatalogSchema {
   [key: string]: z.ZodFirstPartySchemaTypes | z.ZodDiscriminatedUnion<any, any>;
 }
 
+const graphileLogger = new GraphileLogger((scope) => {
+  return (level, message, meta) => {
+    logger.debug(`[graphile-worker][${level}] ${message}`, { scope, meta });
+  };
+});
+
 const RawCronPayloadSchema = z.object({
   _cron: z.object({
     ts: z.coerce.date(),
@@ -168,6 +179,7 @@ export class ZodWorker<TMessageCatalog extends MessageCatalogSchema> {
       taskList: this.#createTaskListFromTasks(),
       parsedCronItems,
       forbiddenFlags: this.#rateLimiter?.forbiddenFlags.bind(this.#rateLimiter),
+      logger: graphileLogger,
     });
 
     if (!this.#runner) {
