@pgflow/edge-worker v0.1.17

A task queue worker for Supabase Edge Functions that extends background tasks with useful features.

!NOTE This project is licensed under AGPL v3 license and is part of pgflow stack. See LICENSING_OVERVIEW.md in root of this monorepo for more details.

What is Edge Worker?

Edge Worker processes messages from a queue and executes user-defined functions with their payloads. It builds upon Supabase Background Tasks to add reliability features like retries, concurrency control and monitoring.

Key Features

• ⚡ Reliable Processing: Retries with configurable delays
• 🔄 Concurrency Control: Limit parallel task execution
• 📊 Observability: Built-in heartbeats and logging
• 📈 Horizontal Scaling: Deploy multiple edge functions for the same queue
• 🛡️ Edge-Native: Designed for Edge Functions' CPU/clock limits

How It Works

Edge Function Optimization

Edge Worker is specifically designed to handle Edge Function limitations:

• Stops polling near CPU/clock limits
• Gracefully aborts pending tasks
• Uses PGMQ's visibility timeout to prevent message loss
• Auto-spawns new instances for continuous operation
• Monitors worker health with database heartbeats

Documentation

For detailed documentation and getting started guide, visit pgflow.dev.