Автономная платформа восстановления workflow

-- Атомарный инкремент retry-сессии CREATE OR REPLACE FUNCTION increment_retry_session(...) RETURNS JSON AS $$ DECLARE v_new_attempt INTEGER; v_delay INTEGER; v_should_retry BOOLEAN; v_should_send_alert BOOLEAN := false; BEGIN -- 1. Проверяем текущее состояние SELECT attempt_number, status INTO v_current_attempt, v_current_status FROM workflow_retries WHERE retry_session_id = p_session_id; -- 2. Если лимит достигнут - НЕ инкрементируем IF v_current_attempt >= p_max_attempts THEN RETURN json_build_object(..., 'should_send_alert', false); END IF; -- 3. Атомарный UPSERT с инкрементом INSERT INTO workflow_retries (...) ON CONFLICT (retry_session_id) DO UPDATE SET attempt_number = workflow_retries.attempt_number + 1, ... RETURNING attempt_number INTO v_new_attempt; -- 4. Вычисляем backoff с jitter v_delay := LEAST(30 * POWER(2, v_new_attempt - 1) + (RANDOM() * 10)::INTEGER, 3600); -- 5. КРИТИЧНО: только первый Handler меняет статус на 'failed' IF NOT v_should_retry THEN UPDATE workflow_retries SET status = 'failed' WHERE retry_session_id = p_session_id AND status = 'retrying'; v_should_send_alert := FOUND; -- PostgreSQL magic! END IF; RETURN json_build_object( 'attempt_number', v_new_attempt, 'should_retry', v_should_retry, 'should_send_alert', v_should_send_alert, ← ключевой флаг! ... ); END; $$ LANGUAGE plpgsql;