diff --git a/pkgs/edge-worker/src/MessageExecutor.ts b/pkgs/edge-worker/src/MessageExecutor.ts index feb46b2..7effda8 100644 --- a/pkgs/edge-worker/src/MessageExecutor.ts +++ b/pkgs/edge-worker/src/MessageExecutor.ts @@ -1,7 +1,7 @@ -import { Json } from './types.ts'; -import { type MessageRecord } from './types.ts'; -import { Queue } from './Queue.ts'; -import { BatchArchiver } from './BatchArchiver.ts'; +import type { Json } from './types.ts'; +import type { MessageRecord } from './types.ts'; +import type { Queue } from './Queue.ts'; +import type { BatchArchiver } from './BatchArchiver.ts'; class AbortError extends Error { constructor() { @@ -45,6 +45,9 @@ export class MessageExecutor { this.signal.addEventListener( 'abort', () => { + console.log( + `################ MessageExecutor aborted during execution: ${this.msgId} ##` + ); reject(new AbortError()); }, { once: true } diff --git a/pkgs/pgflow.dev/src/content/docs/edge-worker/configuration.mdx b/pkgs/pgflow.dev/src/content/docs/edge-worker/configuration.mdx index 31bfd14..d45f3d5 100644 --- a/pkgs/pgflow.dev/src/content/docs/edge-worker/configuration.mdx +++ b/pkgs/pgflow.dev/src/content/docs/edge-worker/configuration.mdx @@ -12,7 +12,13 @@ You can pass an optional configuration object as the second argument to `EdgeWor to tweak the worker's behavior. ### Default configuration