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 }