awesome-repositories.com
Blog
awesome-repositories.com

Descoperă cele mai bune repository-uri open source cu căutare AI.

ExploreazăCăutări recomandateAlternative open-sourceSoftware self-hostedBlogHartă site
ProiectDespreCum realizăm clasamentulPresăServer MCP
LegalConfidențialitateTermeni
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
·

6 repository-uri

Awesome GitHub RepositoriesTask Progress Streams

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.

Awesome Task Progress Streams GitHub Repositories

Găsește cele mai bune repo-uri cu AI.Vom căuta cele mai potrivite repository-uri folosind AI.
  • hatchet-dev/hatchetAvatar hatchet-dev

    hatchet-dev/hatchet

    6,622Vezi pe GitHub↗

    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.

    Goconcurrencydagdistributed
    Vezi pe GitHub↗6,622
  • open-multi-agent/open-multi-agentAvatar open-multi-agent

    open-multi-agent/open-multi-agent

    6,422Vezi pe GitHub↗

    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.

    TypeScriptagent-frameworkagent-orchestrationagentic-ai
    Vezi pe GitHub↗6,422
  • nilsherzig/llocalsearchAvatar nilsherzig

    nilsherzig/LLocalSearch

    5,956Vezi pe GitHub↗

    LLocalSearch este un motor de căutare axat pe confidențialitate și un framework de agenți care utilizează modele de limbaj mari găzduite local pentru a căuta pe internet și a agrega răspunsuri. Acesta funcționează ca o interfață de retrieval augmented generation unde toate interogările și procesarea rămân pe hardware-ul propriu al utilizatorului pentru a asigura confidențialitatea datelor și a elimina dependența de furnizorii externi de API-uri cloud. Sistemul folosește un lanț de agenți autonomi care efectuează căutări recursive pe internet, apelând instrumente de căutare de mai multe ori pentru a colecta și sintetiza informații. Coordonează aceste modele pentru a raționa prin interogări complexe, oferind un flux în timp real de log-uri și citări ale surselor pentru a monitoriza procesul de raționament al agentului. Proiectul include capabilități pentru gestionarea conversațiilor cu stare (stateful) pentru a susține dialoguri multi-turn și rafinări iterative. Integrează regăsirea informațiilor bazată pe instrumente și inferența modelului local pentru a oferi un pipeline complet de la căutarea inițială până la generarea răspunsului final.

    Pushes real-time logs and source citations of the agent's reasoning process directly to the user interface.

    Go
    Vezi pe GitHub↗5,956
  • mervinpraison/praisonaiAvatar MervinPraison

    MervinPraison/PraisonAI

    5,592Vezi pe GitHub↗

    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.

    Pythonagentsaiai-agent-framework
    Vezi pe GitHub↗5,592
  • rmosolgo/graphql-rubyAvatar rmosolgo

    rmosolgo/graphql-ruby

    5,448Vezi pe GitHub↗

    GraphQL-Ruby este o bibliotecă Ruby pentru construirea de API-uri GraphQL cu o schemă puternic tipizată și un motor dedicat de execuție a interogărilor. Aceasta oferă un framework cuprinzător pentru maparea obiectelor aplicației la un sistem formal de tipuri, permițând preluarea structurată a datelor prin resolver-e definite. Proiectul se distinge prin mecanisme avansate de performanță și livrare, inclusiv un data loader pentru batching și caching, menit să prevină tiparele de interogare N+1. Suportă livrarea de date de înaltă performanță prin streaming incremental de răspunsuri, răspunsuri amânate la interogări și preluarea paralelă a datelor folosind fibers. În plus, oferă suport nativ pentru convențiile Relay, inclusiv helper-e specializate pentru conexiuni și identificarea obiectelor. Biblioteca acoperă o suprafață largă de gestionare a API-urilor, incluzând controlul accesului granular, versionarea schemei pentru a menține compatibilitatea backward și actualizări în timp real prin subscripții. Include, de asemenea, instrumente de gestionare a traficului pentru a proteja resursele serverului, cum ar fi limitarea complexității interogărilor și limitarea ratei de cereri. Dezvoltarea și observabilitatea sunt susținute prin instrumente de analiză AST, tracing de execuție și utilitare de testare specializate pentru verificarea încărcării în loturi (batch loading).

    Sends critical data immediately and follows up with secondary fields to enable progressive page loading.

    Ruby
    Vezi pe GitHub↗5,448
  • atmosphere/atmosphereAvatar Atmosphere

    Atmosphere/atmosphere

    3,780Vezi pe GitHub↗

    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.

    Javaacpagentic-aiembabel
    Vezi pe GitHub↗3,780
  1. Home
  2. Web Development
  3. Real-Time Data Streaming
  4. Task Progress Streams

Explorează sub-etichetele

  • Orchestration Progress StreamsReal-time streaming of task decomposition and assignment events from an orchestrator. **Distinct from Task Progress Streams:** Focuses on the streaming of the DAG structure during orchestration rather than simple task progress updates.
  • Progressive Response StreamingPrioritizing critical data delivery and following up with secondary fields as they resolve. **Distinct from Task Progress Streams:** Focuses on the prioritization of fields for progressive loading, whereas Task Progress Streams focuses on the state of a running task.