Queues archiving via edge function

I'm working on implementing Queues (pgmq) like suggested in the tutorial. I have RLS and Expose Queues via PostgREST enabled but i'm only accessing them directly with edge functions. I can't seem to get the edge function to archive it. Are there any edge function examples out there that share the code? I don't see the edge fucntion code in the example https://youtu.be/UEwfaElBnZk . Everything appears to be working other than the deno code to move it to the archive a_queue_name. As in my function is adding, processing, and removing them from the queue... just not the history.
YouTubeSupabase
Supabase Queues allow you to store a sequence of messages allowing for batch processing, or long running asynchronous tasks. In this video, Jon Meyers demonstrates how to add and remove messages in the Queue from a Supabase Edge Function, and how to retry a message if it fails to be processed.

✍️ Supabase Queues (blog): https://supabase.com/blo...
Was this page helpful?