6 Repos
Pushes real-time progress data from a running task to subscribers using the context's stream API.
Distinct from Real-Time Data Streaming: Distinct from Real-Time Data Streaming: focuses on streaming progress data from a specific task execution, not general server-side data updates.
Explore 6 awesome GitHub repositories matching web development · Task Progress Streams. Refine with filters or upvote what's useful.
Hatchet is an open-source durable workflow engine and task orchestration platform. It provides a framework for building and executing fault-tolerant, multi-step pipelines as directed acyclic graphs (DAGs), with automatic retries, scheduling, and real-time observability. The system is built around durable task checkpointing, which persists execution state after each step so work can resume from the last checkpoint after a worker crash or restart, and it supports event-driven task resumption that pauses a task until a matching external event arrives. The platform distinguishes itself through it
Pushes real-time progress data from a running task to subscribers using the context's stream API.
Open Multi-Agent is a TypeScript framework for multi-agent orchestration that decomposes natural language goals into a runtime-generated directed acyclic graph of tasks. It functions as a task orchestrator and workflow state manager, coordinating multiple AI models to execute parallel and sequential operations. The framework is distinguished by a proposer-judge consensus protocol used to validate agent outputs through a quorum of agreement. It employs provider-agnostic model routing to assign specific models to tasks based on roles or execution phases and utilizes state-based workflow checkpo
Emits real-time updates as the coordinator decomposes and assigns tasks to agents.
LLocalSearch ist eine datenschutzorientierte Suchmaschine und ein Agenten-Framework, das lokal gehostete Large Language Models verwendet, um das Internet zu durchsuchen und Antworten zu aggregieren. Es fungiert als Retrieval-Augmented-Generation-Schnittstelle, bei der alle Abfragen und Verarbeitungen auf der eigenen Hardware des Benutzers verbleiben, um den Datenschutz zu gewährleisten und die Abhängigkeit von externen Cloud-API-Anbietern zu beseitigen. Das System verwendet eine Kette autonomer Agenten, die rekursive Internetsuchen durchführen und Suchtools mehrfach aufrufen, um Informationen zu sammeln und zu synthetisieren. Es koordiniert diese Modelle, um komplexe Abfragen zu durchdenken, und bietet einen Echtzeit-Stream von Protokollen und Quellenangaben, um den Denkprozess des Agenten zu überwachen. Das Projekt umfasst Funktionen für ein zustandsbehaftetes Gesprächsmanagement zur Unterstützung von Multi-Turn-Dialogen und iterativen Verfeinerungen. Es integriert Tool-basierte Informationsabfrage und lokale Modell-Inferenz, um eine vollständige Pipeline von der ersten Suche bis zur endgültigen Antwortgenerierung bereitzustellen.
Pushes real-time logs and source citations of the agent's reasoning process directly to the user interface.
PraisonAI is an autonomous AI agent platform that coordinates multiple LLM-powered agents for research, planning, and execution of complex workflows. It functions as a multi-agent orchestration framework, a workflow builder, and a Model Context Protocol server, while also providing retrieval-augmented generation through vector knowledge bases. Agents can interact via CLI, web, or standardized protocols with sandboxed code execution. The platform distinguishes itself with a rich set of agent communication protocols, including A2A, REST, WebSocket, voice and telephony integration, and MCP, allo
Streams real-time job progress updates via Server-Sent Events for live visibility.
GraphQL-Ruby ist eine Ruby-Bibliothek zum Erstellen von GraphQL-APIs mit einem stark typisierten Schema und einer dedizierten Query-Execution-Engine. Sie bietet ein umfassendes Framework zum Mappen von Anwendungsobjekten auf ein formales Typsystem, was strukturiertes Datenabrufen durch definierte Resolver ermöglicht. Das Projekt zeichnet sich durch fortschrittliche Performance- und Bereitstellungsmechanismen aus, darunter einen Data Loader für Batching und Caching zur Vermeidung von N+1-Abfragemustern. Es unterstützt leistungsstarke Datenbereitstellung durch inkrementelles Response-Streaming, verzögerte Abfrageantworten und paralleles Datenabrufen mittels Fibers. Zudem bietet es native Unterstützung für Relay-Konventionen, einschließlich spezialisierter Helfer für Connections und Objektidentifikation. Die Bibliothek deckt ein breites Spektrum an API-Management ab, einschließlich fein abgestufter Zugriffskontrolle, Schema-Versionierung zur Wahrung der Abwärtskompatibilität und Echtzeit-Updates via Subscriptions. Sie enthält zudem Traffic-Management-Tools zum Schutz von Serverressourcen, wie z. B. die Begrenzung der Abfragekomplexität und Request-Rate-Limiting. Entwicklung und Observability werden durch AST-Analysewerkzeuge, Execution-Tracing und spezialisierte Test-Utilities zur Verifizierung von Batch-Loading unterstützt.
Sends critical data immediately and follows up with secondary fields to enable progressive page loading.
Atmosphere is a Java-based framework for building and coordinating AI agents. It provides a real-time transport layer for streaming data via WebSockets, SSE, gRPC, and WebTransport, alongside a multi-agent orchestration framework for managing agent fleets through sequential, parallel, and graph-based execution workflows. The project features a durable workflow engine that persists agent state as snapshots, allowing long-running tasks to survive system restarts and incorporate human-in-the-loop approvals. It also implements Model Context Protocol servers to expose tools, resources, and prompt
Uses server-sent events to provide real-time incremental progress updates for long-running tasks.