Merge branch 'main' of github.com:pgflow-dev/pgflow

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 }

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