---

[I128-2795] Расширить Queue как runtime фоновых заданий, retry и расписаний

---

НАЧАЛО >> Оглавление >> Общее описание >> История изменений >> Что нового в проекте I128 >> Версия 2026.3 >> [I128-2795] Расширить Queue как runtime фоновых заданий, retry и расписаний📄 Скачать в DOCX

---

Тип	Версия	Статус	Приоритет	Исполнитель
⚙️ Новые возможности	2026.3	🔘 Завершено	Средний	Ilya Mikhaylenko

Компоненты: ИРБИС 128. Модуль Queue - Очередь задач

Завершено: 09.09.2026 07:27

1. Цель Расширить Queue до системного runtime фоновых заданий, повторов, расписаний, deadletter и workerуправления для промышленных модулей ИРБИС 128.

2. Контекст Queue должна выполнять тяжелые, отложенные, повторяемые и плановые операции, которые нельзя надежно выполнять в пользовательском запросе. Queue не должна знать доменную структуру Tasks, Workflow*, EventBus, FT или других модулей: модуль-владелец регистрирует handler и определяет payload, а Queue управляет выполнением.

3. Что Нужно Сделать

• Ввести модель QueueJob: ключ, тип handler-а, владелец, queue channel, priority, status, payload profile, trace id, idempotency key, created/started/finished timestamps, progress, result и error summary.

• Ввести queue channels и priority policy: разные классы заданий должны выполняться в предсказуемом порядке и не блокировать друг друга.

• Ввести handler registry: модуль-владелец регистрирует обработчик, описание параметров, expected result, retry policy, timeout, права запуска и диагностический contract.

• Реализовать worker runtime: выбор задания, блокировка на выполнение, heartbeat, timeout, graceful stop, защита от двойного выполнения и восстановление после падения worker-а.

• Реализовать retry policy: max attempts, backoff, jitter, retryable/non-retryable errors, next run time, ручной retry с проверкой прав.

• Реализовать deadletter для заданий, которые больше нельзя автоматически повторять. Deadletter должен иметь видимую причину, diagnostic payload и безопасный сценарий восстановления.

• Реализовать scheduling: задания по времени нужны для SLA, напоминаний, подписок на фильтры, очистки временных файлов, пересчета materialized views и maintenance-процессов.

• Реализовать joblevel idempotency, не подменяя бизнесидемпотентность EventBus.

• Реализовать защиту payload: секреты и скрытые данные не должны попадать в UI, логи, TestA evidence и экспорт диагностики.

• Интегрировать Queue с TraceContext, EventBus, Security, HealthCheck и Observability.

  1. Границы Ответственности

• Queue управляет runtime выполнения, но не реализует доменную логику handlers.

• Queue не является event log и не должна хранить историю предметных действий вместо EventBus или 907.

• Queue не должна обходить Security: права на запуск, просмотр, retry и отмену заданий проверяются общим механизмом.

  1. Критерии Приемки

• Handler модуля-владельца можно зарегистрировать и выполнить без изменения ядра Queue.

• Задание нельзя выполнить дважды при конкурентных worker-ах или повторе запроса.

• Retry/backoff/timeout работают по policy, а окончательная ошибка попадает в dead-letter.

• Scheduled jobs запускаются в нужное время и видны в диагностике.

• Администратор может безопасно посмотреть статус, прогресс, ошибку и выполнить ручной retry, если имеет право.

• Payload и error output маскируются перед показом пользователю и попаданием в отчет.

  1. Проверки И Документация Нужно подготовить TestAсценарии для постановки job, выполнения handlerа, конкурентного lock, retry, timeout, deadletter, manual retry, scheduling, idempotency, trace propagation, прав доступа и HealthCheck provider. В Help нужно описать handler contract, настройку workerов, мониторинг, восстановление и безопасный retry.

-

Первый кодовый срез по I1282795: общий runtimeконтракт Queue для фоновых заданий, retry, scheduling и диагностики.

Сделано:

• добавлены QueueHandlerDefinition и QueueJobContext;
• добавлен runtime registry handler-ов и каналов Queue;
• добавлены NormalizeJobOptions и AppendRegisteredJob для постановки задания через зарегистрированный handler;
• добавлены queueTraceId, queueIdempotencyKey, queuePayloadFingerprint, queueSourceRef и queueRetryPolicy в нормализованные options;
• добавлена поддержка scheduledAt/started в SqlInsert без изменения старого поведения started=0;
• добавлены BuildQueueRuntimeContext, BuildDeadLetterEntry и MoveJobToDeadLetter;
• добавлен HealthCheck_Self provider Queue;
• добавлены system/queue-core.json и Help/DeveloperGuide.md;
• расширено TestAпокрытие Queue: saferead контракт и isolated write-проверка SqlInsert.

Границы:

• Queue не содержит бизнес-логику Tasks, Workflow или EventBus;
• EventBus остается владельцем событийной idempotency и delivery contract;
• доменные модули остаются владельцами применения изменений и повторной проверки прав/состояния;
• Queue отвечает за runtime задания, техническую дедупликацию задания, расписание, retry/dead-letter и диагностический контекст.

Проверка:

• php -l modules/Queue/api.php;
• php -l modules/Queue/__call/SqlInsert.inc;
• php -l modules/Queue/Tests/Module.inc;
• php -l modules/Queue/Tests/__call/SqlInsert.inc;
• ConvertFromJson modules/Queue/system/queuecore.json;
• TestA Queue saferead: 56/56 passed, runid I1282795queuecontract-2;
• TestA Queue SqlInsert writes/queue isolated: 2/2 passed, runid I1282795queuesqlinsertwrites-1;
• git diff -cached -check.

1. Связанные задачи

1.1. 🔗 blocks: I128-2796

1.2. 🔗 blocks: I128-2805

1.3. 🔗 blocks: I128-2808

1.4. 🔗 blocks: I128-2809

1.5. 🔗 blocks: I128-2810

1.6. 🔗 blocks: I128-2811

1.7. 🔗 blocks: I128-2817

1.8. 🔗 blocks: I128-2818

1.9. 🔗 blocks: I128-2820

1.10. 🔗 blocks: I128-2821

1.11. 🔗 blocks: I128-2822

1.12. 🔗 blocks: I128-2824

1.13. 🔗 blocks: I128-2827

1.14. 🔗 blocks: I128-2830

1.15. 🔗 blocks: I128-2832

1.16. 🔗 blocks: I128-2837

1.17. 🔗 blocks: I128-2838

1.18. 🔗 blocks: I128-2839

1.19. 🔗 blocks: I128-2840

1.20. 🔗 blocks: I128-2793

1.21. 🔗 relates to: I128-2792