Пользователь описывает задачу на естественном языке в панели чата ИИ-ассистента.
Ассистент определяет проект из контекста панели и работает строго в нём.
Ассистент уточняет имена соединений-источника и приёмника (или создаёт их из URL PostgreSQL).
Ассистент предлагает выбрать существующее QUEUE-соединение (Kafka) или создать новое (запросив брокеры и топик).
Ассистент проверяет соединения (test_connection), читает метаданные баз (read_db_schema).
Ассистент предлагает значения слота, публикации и режима публикаций для захвата CDC на источнике (set_capture_options).
Пользователь подтверждает предложенные значения. Только после подтверждения ассистент применяет их повторным вызовом set_capture_options с теми же значениями.
Ассистент выбирает или создаёт конфигурации модулей (capture и applier).
Ассистент собирает граф репликации (build_replication_graph).
При необходимости ассистент настраивает маппинг таблиц (set_table_mapping).
Ассистент выполняет валидацию графа (validate_graph), при ошибках исправляет и повторяет проверку.
Ассистент предлагает граф к согласованию (propose_apply).
Пользователь согласовывает граф кнопкой «Согласовать граф» в панели.
Запуск процессов репликации выполняет пользователь на странице «Графы» после согласования.
Если ассистент обнаруживает неоднозначность (несколько соединений с подходящим именем, отсутствие очереди), он задаёт уточняющий вопрос.
Если валидация графа выдаёт ошибки (несоответствие схем, отсутствие слота/публикации), ассистент пытается исправить их автоматически и повторяет проверку.
Если пользователь не согласовывает предложенный граф, граф остается несогласованным и не запускается. Пользователь может продолжить диалог с ассистентом и уточнить требования к графу.
Если пользователь прерывает диалог, текущая сессия сохраняется и может быть возобновлена через вкладку «Журнал работ».