A lightweight distributed Python runtime

Task queue, Long lived workers for work based parallelization, with processes and Redis as back-end. For distributed computing.

distributed system for scalable, asynchronous background task processing

Reliable Python message queuing with Redis and built-in deduplication. Publish once, process once, recover from crashes - across any number of producers and consumers.

Tentacule is an uncomplicated library to deal with a pool of worker processes

Pipeline Factory is a Python server framework to define, manage, schedule and execute custom defined code pipelines and series of pipeline across multiple worker processes.

Async PDF generation in Django Channels worker or with Django 3.1 async views

Custom server uptime monitor for STUN, TURN, MQTT, and NTP

Kafka Consumer loop a "worker" running infinitely and listening to kafka topic through long pooling

Beta Python concurrency model using token-managed routing

Python library for Twitter automation via streaming APIs

Dockerized multi-container distributed batch inference service on the MNIST dataset (in progress)

Enables real time user-presence functionality which marks user active/inactive based on last user activity using heartbeat mechanism, received from the client (here: mouse-up mouse-down movements) and comparing it with a threshold time quantum.

A Python worker pool allowing rate and concurrency control