How are you handling the durable execution state? I built a similar orchestration layer for a book generation pipeline using Celery and Redis, but managing the websocket stability and intermediate state for ComfyUI was a nightmare. Curious if this is a custom implementation on top of Postgres or if you're using something like Temporal.