Awesome GitHub RepositoriesDistributed Processing

Open WebUI is a self-hosted, web-based platform designed for interacting with local and remote artificial intelligence models. It functions as a unified interface and orchestration suite, enabling users to build, deploy, and manage specialized AI agents equipped with custom instructions, external tool access, and private knowledge bases. The platform distinguishes itself through a modular architecture that supports complex AI workflows. It features a plugin-based framework for custom logic and pipeline-based request processing, allowing developers to filter or transform data streams before th

Airflow is a workflow orchestration platform for authoring, scheduling, and monitoring complex data pipelines as code using Python. It employs a DAG-based task scheduler to manage execution timing and dependencies via directed acyclic graphs, utilizing a distributed task execution engine to run workloads across a cluster of worker nodes. The platform provides a data pipeline monitor for tracking the health and execution history of programmatic workflows. This includes a web interface for workflow progress visualization and health monitoring to identify and troubleshoot pipeline failures. The

Fastai is a high-level deep learning library built on PyTorch that provides a unified interface for managing the entire machine learning lifecycle. It functions as a comprehensive training toolkit, abstracting hardware management and automating complex training loops to simplify the construction and execution of neural network models. The framework is distinguished by its notebook-centric development environment and a type-dispatching data pipeline that automatically applies transformations based on input data formats. It emphasizes transfer learning through discriminative layer-wise optimiza

Bull is a Node.js library for managing distributed jobs and message queues using Redis as the primary data store. It functions as a distributed task worker, job scheduler, and priority queue manager designed to handle asynchronous workloads across multiple processes. The project distinguishes itself by providing a persistent communication channel that decouples servers through the exchange of serializable data objects. It ensures distributed system reliability by detecting stalled tasks and recovering from process crashes to ensure every queued job is completed. The system covers a broad ran

ImageMagick is a comprehensive software suite for the creation, editing, composition, and conversion of digital images. It functions as both a command-line utility for batch processing and automation, and as a programming library that allows developers to integrate advanced image manipulation capabilities into external applications. The project is distinguished by its modular architecture, which supports hundreds of image formats through a pluggable coder system and external delegate libraries. It is designed for high-performance environments, utilizing memory-mapped pixel caching, stream-ori

Nightingale is a Prometheus-compatible monitoring and alerting platform designed to centralize telemetry management across multiple time-series databases. It functions as a multi-source alerting engine and metric data pipeline that ingests telemetry via remote write protocols and triggers alarms based on data from sources such as Prometheus, Elasticsearch, Loki, and ClickHouse. The system is distinguished by its automated alert healing system, which executes predefined scripts and RPC-based corrective actions when monitoring thresholds are breached. It supports distributed alert processing, a

Meshroom is a node-based photogrammetry software designed to transform collections of two-dimensional images into three-dimensional models and scene geometry. It provides a visual interface for constructing and managing modular data pipelines, allowing users to automate complex computer vision tasks such as feature extraction, depth map estimation, and mesh generation. The software distinguishes itself through a distributed computational framework that dispatches resource-intensive tasks across local hardware or remote render farms. By utilizing a directed acyclic graph execution model, it en

Synapse is a decentralized communication server implementation that enables real-time messaging and data exchange across the global Matrix federation. It functions as a homeserver, allowing operators to host their own nodes while maintaining control over personal data and user identity within a distributed network. The server utilizes a federated messaging protocol to exchange messages and user data with independent servers, ensuring consistent state across the network. To support high-traffic environments, it employs a distributed service architecture that offloads tasks to independent backg

Colyseus is a real-time multiplayer game framework for Node.js that provides an authoritative server model, delta-compressed state synchronization, and room-based session orchestration. It is designed to handle the core infrastructure of multiplayer games, including matchmaking, state management, and scalable process distribution across multiple servers. The framework distinguishes itself through its schema-based state definition, which enables automatic serialization and change tracking, combined with a binary WebSocket protocol for low-latency updates. Its matchmaking pipeline routes player

KBEngine ist eine verteilte Game-Server-Engine und Backend-Infrastruktur, die für Massively Multiplayer Online-Umgebungen entwickelt wurde. Sie bietet eine Multi-Prozess-Architektur, um hohe Spieler-Gleichzeitigkeit und Echtzeit-Interaktionen innerhalb einer geteilten virtuellen Welt zu bewältigen. Das System bietet ein skriptfähiges Game-Logic-Framework, das einen Hochleistungskern mit einer High-Level-Skriptsprache kombiniert. Dies ermöglicht Modifikationen des Spielverhaltens durch eine Hot-Fix-fähige Runtime, die Logik aktualisiert, ohne dass Server-Neustarts erforderlich sind. Die Engine verwaltet die Server-Skalierung durch dynamisches Load-Balancing über mehrere Hardware-Knoten hinweg und stellt durch Echtzeit-Zustandssynchronisierung zwischen Server und Game-Clients eine konsistente Weltsicht sicher. Sie enthält zudem Mechanismen für die Persistenz von Spieldaten, wie z. B. geplante Entity-Backups und Server-State-Snapshotting. Administrative Funktionen umfassen Live-Server-Debugging-Tools zur Überwachung des Systemstatus und zur Verwaltung von Server-Lebenszyklen.

Tdarr is a distributed video processing and media library automation tool. It functions as a server-node architecture that manages the scanning, analysis, and normalization of audio and video files based on custom rules. The system distributes heavy compute workloads, such as transcoding and health checks, across multiple remote nodes to optimize hardware utilization. It uses a plugin-based pipeline to execute sequences of filters and transformations, automating media conversion via FFmpeg and HandBrake to standardize file formats and containers. The project covers media library health audit

Bee-queue ist ein Node.js-Hintergrundverarbeitungssystem, das Redis für Job-Queueing und Persistenz verwendet. Es wurde entwickelt, um rechenintensive Aufgaben vom Haupt-Execution-Thread auf Hintergrund-Worker auszulagern und so die Reaktionsfähigkeit der Anwendung aufrechtzuerhalten. Das Projekt bietet verteilte Job-Verarbeitung, die es Worker-Nodes ermöglicht, über mehrere Prozesse hinweg zu laufen, um große Mengen an Aufgaben gleichzeitig zu bewältigen. Es stellt eine zuverlässige Aufgabenausführung durch automatische Retries und die Wiederherstellung hängengebliebener Prozesse sicher. Der Funktionsumfang umfasst asynchrones Task-Scheduling für verzögerte Jobs, Concurrency-Control für Worker-Nodes und Job-Lifecycle-Management. Es enthält Tools zur Überwachung des Queue-Status, zur Verfolgung des Job-Fortschritts und zum Abrufen von Ergebnissen basierend auf dem Job-Zustand. Das System unterstützt Bulk-Job-Enqueuing zur Reduzierung des Netzwerk-Overheads und ermöglicht benutzerdefinierte Job-Identifikatoren sowie konfigurierbare Backoff-Strategien für fehlgeschlagene Aufgaben.