pub fn upsert_queue_head_in_db( conn: &Connection, document_id: &str, queue_name: &str, head_id: Option<&str>, prompt: &str, state: &str, ) -> Result<()>