refactor(worker): rename maxConcurrency to maxConcurrent

Update Worker configuration parameter name across multiple files to improve naming consistency.
This includes changes in Worker.ts, index.ts, and README.md to reflect the new parameter name.

Fixes naming inconsistency in worker configuration

pkgs/supaworker/src/Worker.ts

@@ -22,7 +22,7 @@ export interface WorkerConfig {
   maxPollSeconds?: number;
   pollIntervalMs?: number;
   maxPgConnections?: number;
-  maxConcurrency?: number;
+  maxConcurrent?: number;
 }
 
 export class Worker<MessagePayload extends Json> {
@@ -47,7 +47,7 @@ export class Worker<MessagePayload extends Json> {
       maxPollSeconds: config.maxPollSeconds ?? 5,
       pollIntervalMs: config.pollIntervalMs ?? 100,
       maxPgConnections: config.maxPgConnections ?? 4,
-      maxConcurrency: config.maxConcurrency ?? 50,
+      maxConcurrent: config.maxConcurrency ?? 50,
     };
 
     this.sql = postgres(this.config.connectionString, {
@@ -59,7 +59,7 @@ export class Worker<MessagePayload extends Json> {
     this.executionController = new ExecutionController(
       this.queue,
       this.mainController.signal,
-      this.config.maxConcurrency
+      this.config.maxConcurrent
     );
   }
 

pkgs/supaworker/supabase/functions/serial-sleep-worker/index.ts

@@ -3,4 +3,4 @@ import { delay } from 'jsr:@std/async';
 
 const sleep1s = () => delay(1000);
 
-Supaworker.start(sleep1s, { maxConcurrency: 1 });
+Supaworker.start(sleep1s, { maxConcurrent: 1 });

pkgs/supaworker/tests/e2e/README.md

@@ -41,8 +41,8 @@ functions/
 - [x] Worker picks messages from queue
 - [ ] Worker calls handler function with each message
 - [x] Worker can process big amounts of messages (restarts itself when CPU clock limit hits)
-- Different worker functions can pull from different queues
-- [ ] Drent worker functions can pull from the same queue
+- [ ] Different worker functions can pull from different queues
+- [ ] Different worker functions can pull from the same queue
 
 ✅ Worker Lifecycle
 
@@ -59,4 +59,4 @@ functions/
 
 ✅ Concurrency
 
-- [ ] Worker respects maxConcurrency (does not read new messages if there are no empty slots, reads max empty-slots-count of messages)
+- [ ] Worker respects maxConcurrent (does not read new messages if there are no empty slots, reads max empty-slots-count of messages)