rule-engine-core

Shared domain library for the rule-engine platform, published to PyPI as rule-engine-core. The three FastAPI services (metadata_service, position_server, platform_service, rule_engine) all depend on it.

What's in it

• Expression parser (parser.py) — recursive-descent parser turning an infix rule/filter expression into a Node tree (! & |, comparisons, arithmetic, parentheses; AND/OR/NOT are accepted as aliases).
• Entities — Rule and Filter (both extend EntityBase) with validate() and evaluate() over metadata fields and nested entities.
• MetadataStore — loads column metadata from a JSON file or over HTTP.
• Postgres DAOs — EntityDao (rules/filters, persisted as pickled objects) and MetadataDao (the metadata table).
• DbPool — thread-safe psycopg2 connection pool; one connection per unit of work via with pool.acquire() as conn:.
• tracing — lightweight X-Trace-Id propagation (contextvars + log stamping
  • thread/pool helpers) shared across services.

Install

pip install rule-engine-core

Build & publish (manual)

setup.py reads its dependencies from $BUILD_PATH/requirements.txt, so BUILD_PATH must be set.

python -m pip install --upgrade setuptools wheel twine
cd rule-engine-core
BUILD_PATH="$(pwd)" python setup.py sdist bdist_wheel
twine upload dist/*

Releases are normally cut automatically — see .github/workflows/publish.yml, which publishes to PyPI (then builds the service images) after CI passes on main.

Note on the pickle serialization contract

Rules and filters are stored in Postgres as pickled Python objects, and entity_dao.py installs sys.modules aliases so older pickles still load. Renaming/moving core modules or changing EntityBase's pickled fields can break unpickling of already-stored entities — treat these as a compatibility contract.