- задачи обернуты в try/except для стабильной работы планировщика - добавлена защита от сбоев при запуске scheduler - ошибки логируются, планировщик продолжает работу при возникновении исключений

добавлены healthcheck для всех сервисов

Добавил healthcheck:

- Переместил инициализацию CORS middleware в конец, после всех mount и include_router, чтобы корректно обернуть все маршруты. - Заменил импорт на starlette.middleware.cors.CORSMiddleware для большей стабильности при работе с FastAPI.

Отключил allow_credentials в CORS middleware, чтобы корректно работала настройка allow_origins=["*"] и разрешались запросы со всех источников без ограничений по доменам.

refactor: переход с Redis Streams на Pub/Sub для уведомлений

- закрыто соединение для redis из вне

- Установлен параметр no_ack=True в подписках на стримы message_queue и bot_message_queue - Теперь Redis автоматически помечает сообщения как доставленные без необходимости XACK - Упрощена обработка уведомлений от каналов и ботов - Преднамеренно отключена надёжность доставки, т.к. потеря отдельных уведомлений допустима

- Добавлен healthcheck для Redis (ping каждые 5 секунд) - Добавлен healthcheck для Postgres через pg_isready с указанием порта и пользователя - Обновлены depends_on для всех сервисов: теперь они дожидаются полной готовности Redis и Postgres - Улучшена стабильность запуска faststream-сервисов при старте docker-compose

- Добавлена инициализация Redis-стримов через xadd при запуске приложения - Реализована фонова задача для обработки зависших сообщений с помощью xpending/xclaim

- Удалён параметр `--workers` из запуска FastStream. - Теперь каждый контейнер запускает один процесс с уникальным consumer_id. - Это устраняет конфликты между воркерами внутри одного контейнера

Добавление логирования ошибок при обработке сообщений

Добавлена настройка `restart: unless-stopped` в конфигурации контейнеров в docker-compose.

update: удаление устаревших задач, не связанных с эмиттерами

update: мягкое обновление задач эмиттеров без сброса next_run_time

update: добавлена фоновая синхронизация эмиттеров через APScheduler

fix: Убрана сортировка связей по приоритету

fix: Добавлена сортировка связей по приоритету

fix: Исправлен вывод ошибки при отправке сообщения сокетом

fix: Исправлена подписка на канал - добавлена проверка на наличие первого шага