diff --git a/apps/webapp/app/platform/zodWorker.server.ts b/apps/webapp/app/platform/zodWorker.server.ts index ccced41ed..17a8634fe 100644 --- a/apps/webapp/app/platform/zodWorker.server.ts +++ b/apps/webapp/app/platform/zodWorker.server.ts @@ -208,7 +208,7 @@ export class ZodWorker { this.#logDebug("Detected incoming migration", { latestMigration }); if (latestMigration > 10) { - // already migrated past v0.14 - nothing to do + this.#logDebug("Already migrated past v0.14 - nothing to do", { latestMigration }); return; } diff --git a/apps/webapp/app/services/db/graphileMigrationHelper.server.ts b/apps/webapp/app/services/db/graphileMigrationHelper.server.ts index c852ad731..f10f3db76 100644 --- a/apps/webapp/app/services/db/graphileMigrationHelper.server.ts +++ b/apps/webapp/app/services/db/graphileMigrationHelper.server.ts @@ -86,6 +86,8 @@ export class GraphileMigrationHelperService { ); IF max_payloads IS NOT NULL + -- we only add payloads one at a time so batches will never exceed max_payloads + -- if we ever decide to enqueue more, this will have to be adjusted to prevent oversized batches AND json_array_length(v_job.payload) >= max_payloads THEN UPDATE ${env.WORKER_SCHEMA}._private_jobs SET run_at = NOW() diff --git a/apps/webapp/app/services/worker.server.ts b/apps/webapp/app/services/worker.server.ts index b7c1e35de..fd031f810 100644 --- a/apps/webapp/app/services/worker.server.ts +++ b/apps/webapp/app/services/worker.server.ts @@ -188,10 +188,6 @@ export async function init() { const migrationHelper = new GraphileMigrationHelperService(); await migrationHelper.call(); - // const pgNotify = new PgNotifyService(); - // await pgNotify.call("trigger:graphile:migrate", { latestMigration: 10 }); - // await new Promise((resolve) => setTimeout(resolve, 10000)) - if (env.WORKER_ENABLED === "true") { await workerQueue.initialize(); }