I have a worker that runs periodically that executes a function in Postgres. This function reads from m