From 3529aa4d73866748a47f2d9afa6c27d43fe95344 Mon Sep 17 00:00:00 2001
From: Wojtek Majewski <wojciech.majewski@pm.me>
Date: Wed, 22 Jan 2025 07:25:33 +0100
Subject: [PATCH 1/2] docs(edge-worker): update configuration documentation
 example

Minor text improvement in configuration documentation, adding a simple usage example and tweaking
default description wording
---
 .../src/content/docs/edge-worker/configuration.mdx        | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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.
 
 <Aside title="Zero configuration needed" type="tip">
-All configuration options are optional and have sane defaults.
+All configuration options are optional and have good defaults.
+
+You only need to provide the handler function:
+
+```ts
+EdgeWorker.start(console.log);
+```
 </Aside>
 
 ### Default configuration

From 0b6b3e3825754e18906220f6c0531d1fa4d2354e Mon Sep 17 00:00:00 2001
From: Wojtek Majewski <wojciech.majewski@pm.me>
Date: Wed, 22 Jan 2025 07:27:01 +0100
Subject: [PATCH 2/2] refactor(types): update import statements to use type
 keyword

Add debug logging for MessageExecutor abort event
---
 pkgs/edge-worker/src/MessageExecutor.ts | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

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<MessagePayload extends Json> {
           this.signal.addEventListener(
             'abort',
             () => {
+              console.log(
+                `################ MessageExecutor aborted during execution: ${this.msgId} ##`
+              );
               reject(new AbortError());
             },
             { once: true }