Skip to main content

Multi-provider LLM and message queue abstraction for distributed agent systems

Project description

teenyfactories

Agent runtime for TeenyFactories. Postgres-backed pub/sub, multi-provider LLM calls, vector search.

pip install --pre teenyfactories
import teenyfactories as tf

@tf.on_state('documents', 'loaded').do
def analyse(item):
    tf.collection('documents').set(item['key'], state='analysed')

while True:
    tf.run_pending()
    tf.sleep(1)

Writing a row into a (collection, state) makes every subscriber to that pair pick it up: (collection, state) is a FIFO queue, and the handler consumes a row by transitioning its state (or deleting it). That's the framework.

Public API

Group Names
Pub/sub on_state, run_pending (the only pub/sub primitive — no message bus)
Data collection (.set, .add, .get, .get_all, .remove, .count, .exists, .first, .state, .where, .limit, .vector_search), embed
LLM llm (fluent builder — .ask / .run_agent_loop), call_llm (LEGACY)
MCP add_mcp_server, add_mcp_tool
Schedule on_schedule.every(N).<unit>.do(handler)
Secrets / files secrets, bucket_store (+ BucketStoreError family)
Logging log_debug, log_info, log_warn, log_error, log_persona
Time / IDs get_timestamp, get_timestamp_utc, generate_unique_id
Debug breakpoint
Lifecycle / config sleep, shutting_down, FACTORY_NAME, AGENT_NAME, AGENT_SLUG, AGENT_ID, __version__

Anything not in this list is not part of the supported surface — don't reach into submodules.

How it plugs in

A factory is a directory:

my_factory/
├── factory.yml
└── agents/
    ├── poller.py
    └── enricher.py

Each agents/*.py runs in its own container based on ghcr.io/teenyfactories/agent:dev — which has this library pre-installed. Single-factory mode runs each file as a docker compose service; multi-factory mode runs them under the orchestrator. Either way, agent code is just import teenyfactories as tf + handlers + main loop.

Full setup, compose templates, environment variable reference: see the core repo.

Versioning

PEP 440 dev pre-releases: 0.1.0.devYYYYMMDD. pip install teenyfactories will NOT pick these up — you need --pre (latest dated build) or an explicit pin (teenyfactories==0.1.0.dev20260512).

License

MIT.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

teenyfactories-0.1.0.dev20260720.tar.gz (95.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

teenyfactories-0.1.0.dev20260720-py3-none-any.whl (102.8 kB view details)

Uploaded Python 3

File details

Details for the file teenyfactories-0.1.0.dev20260720.tar.gz.

File metadata

File hashes

Hashes for teenyfactories-0.1.0.dev20260720.tar.gz
Algorithm Hash digest
SHA256 af9f3b89e2cbb45744c759bc6e4a754cc33fb04327038731b22332a0157abb58
MD5 fef2f8ec5717b6231a84637e23578941
BLAKE2b-256 f16dde5f37b741650f8fa80791133e2a72f0c7bd85bdb9290d9b331e2a2bd208

See more details on using hashes here.

File details

Details for the file teenyfactories-0.1.0.dev20260720-py3-none-any.whl.

File metadata

File hashes

Hashes for teenyfactories-0.1.0.dev20260720-py3-none-any.whl
Algorithm Hash digest
SHA256 1d76f16a6c87d154dfbac8c600583ca6a97ed804195dadc30dbf2eca377b9740
MD5 14fc7d90f70dcd41f6ff16b8e1029468
BLAKE2b-256 420fd22eeb146127d99f1dc9697c6fb196f187bced57cfbe13ee397d7891d12f

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page