No description
- Python 99.4%
- Dockerfile 0.6%
Denis
c6968552e3
- Compute next_version (max active version + 1) per partner+service pair - Set valid_to and superseded_by_item_id on deactivated items - Persist version on newly activated items Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> |
||
|---|---|---|
| src/app | ||
| tests | ||
| .env.example | ||
| .gitignore | ||
| Dockerfile | ||
| pyproject.toml | ||
| README.md | ||
| uv.lock | ||
Validation Worker
Python worker that consumes ValidateDocumentItemsRequested, validates parsed/matched price items, creates validation issues/review tasks, activates eligible prices, and requests search reindexing.
Run
uv sync
uv run pytest
uv run python -m app.main
Optional health API:
uv run uvicorn app.health:app --host 0.0.0.0 --port 8083
Configuration
See .env.example. Key settings:
DATABASE_URLQUEUE_KIND=redis_streamsREDIS_URLPRICE_SPIKE_THRESHOLD_PERCENT=50ALLOW_FUTURE_EFFECTIVE_DATE=falseALLOW_WARNING_AUTO_ACTIVATION=falseREQUIRE_SOURCE_REF=true
Streams
Consumes ValidateDocumentItemsRequested from QUEUE_TOPIC_VALIDATE_ITEMS and publishes ValidationIssueCreated, ValidationCompleted, ReviewRequired, and SearchReindexRequested.