feat: add worker tracking and graceful shutdown for edge functions

[jumski]

Implement Worker Tracking for Improved Reliability

This PR adds functionality to track edge function workers more effectively, improving the reliability of worker management:

1. Added two new methods to the Queries class:

   • trackWorkerFunction() - Registers an edge function for monitoring by the ensure_workers() cron job
   • markWorkerStopped() - Marks a worker as stopped during graceful shutdown

2. Updated worker lifecycle implementations to call trackWorkerFunction() early in the startup process, which:

   • Sets last_invoked_at to prevent cron from pinging during startup (debounce)
   • Ensures proper monitoring of the worker by the cron job

3. Enhanced the shutdown process in SupabasePlatformAdapter:

   • Replaced the previous approach of spawning a new edge function
   • Now signals worker death to the cron job by setting stopped_at
   • Allows immediate detection of worker termination

4. Added comprehensive unit tests for the new functionality

These changes improve worker reliability by providing better signaling between workers and the monitoring system, ensuring faster recovery from failures and more efficient worker management.

[changeset-bot]

⚠️ No Changeset found

Latest commit: b99dc84

Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. If these changes should result in a version bump, you need to add a changeset.

This PR includes no changesets

When changesets are added to this PR, you'll see the packages that this PR includes changesets for and the associated semver types

Click here to learn what changesets are, and how to add one.

Click here if you're a maintainer who wants to add a changeset to this PR

[jumski]

• fix: clear worker_functions table in reset and enhance worker credential tests #521
• refactor: remove last_invoked_at from track_worker_function to fix debounce handling #520
• feat: add automatic worker restart via cron job and worker health tracking #517
• refactor: add handler spy utilities for queue worker tests #514
• feat: add worker tracking and graceful shutdown for edge functions #513 👈 (View in Graphite)
• feat: add setup_ensure_workers_cron function for worker management #512
• feat: add cleanup function for cron job run details #511
• feat: add ensure_workers function to automatically restart dead workers #510
• feat: add pg_cron, pg_net, pgsodium, and supabase_vault extensions to Atlas database #508
• feat: add mark_worker_stopped function for graceful worker shutdown #506
• feat: add track_worker_function for edge function monitoring #505
• feat: add worker_functions table and stopped_at column to workers #504
• refactor: auto-detect environment in ensure_flow_compiled instead of requiring mode parameter #503
• feat: add is_local() function to detect Supabase CLI environment #502
• refactor: improve Atlas migration management with better baseline handling #507
• main

This stack of pull requests is managed by Graphite. Learn more about stacking.

[nx-cloud]

View your CI Pipeline Execution ↗ for commit b99dc84

Command	Status	Duration	Result
nx run edge-worker:test:integration	✅ Succeeded	3m 54s	View ↗
nx run cli:e2e	✅ Succeeded	4s	View ↗
nx run edge-worker:e2e	✅ Succeeded	48s	View ↗
nx affected -t verify-exports --base=origin/mai...	✅ Succeeded	<1s	View ↗
nx affected -t build --configuration=production...	✅ Succeeded	24s	View ↗
nx affected -t lint typecheck test --parallel -...	✅ Succeeded	22s	View ↗

---

☁️ Nx Cloud last updated this comment at 2025-12-08 09:32:25 UTC

[github-actions]

🔍 Preview Deployment: Website

✅ Deployment successful!

🔗 Preview URL: https://pr-513.pgflow.pages.dev

📝 Details:

• Branch: 12-05-integrate_trackworkerfunction_and_markworkerstopped_into_edge_worker_lifecycle
• Commit: 34a8b8ea1394a3d2a5c72b0d7ca055e03e8ff1df
• View Logs

_Last updated: _

[jumski]

Merge activity

• Dec 8, 8:07 AM UTC: A user started a stack merge that includes this pull request via Graphite.
• Dec 8, 9:26 AM UTC: Graphite rebased this pull request as part of a merge.
• Dec 8, 9:33 AM UTC: @jumski merged this pull request with Graphite.

[github-actions]

🚀 Production Deployment: Website

✅ Successfully deployed to production!

🔗 Production URL: https://pgflow.dev

📝 Details:

• Commit: 88f3a5b9f4bff07d02f452c22289e7ddc409f7a2
• View Logs

Deployed at: 2025-12-08T10:33:24+01:00