16 个仓库
Mechanisms for gathering the outputs and errors of multiple asynchronous tasks into a single unified structure.
Distinguishing note: Unlike result storage, this is about in-memory aggregation of results to prevent execution interruption.
Explore 16 awesome GitHub repositories matching software engineering & architecture · Task Result Aggregation. Refine with filters or upvote what's useful.
Async is a JavaScript asynchronous flow library designed to manage the execution and coordination of asynchronous tasks in Node.js and the browser. It provides functional utilities to wrap, process, and orchestrate complex asynchronous workflows. The library distinguishes itself through a comprehensive task orchestrator that handles dependency graphs to resolve circular references and manages concurrent task queues. It includes a unification bridge that allows callback-style and promise-based functions to operate within the same execution interface. The project covers several primary capabil
Gathers results and errors into a single object to ensure task failures do not interrupt the main execution flow.
This project is a comprehensive Lisp AI implementation library that provides reference implementations for various artificial intelligence paradigms and symbolic algorithms. It functions as a multi-purpose toolkit containing a logic programming engine, a natural language processing suite, and a symbolic mathematics toolkit. The library is distinguished by its diverse architectural frameworks, including a Prolog-style execution engine that uses unification and goal-driven backtracking, and a system for simulating human decision-making through expert system shells and certainty factors. It also
Aggregates all possible results that satisfy a specific logic goal into a comprehensive list.
neverthrow is a TypeScript result type library that implements railway oriented programming. It provides a functional error handling framework using type-safe wrappers to represent operation outcomes as either success or failure variants, eliminating the need to throw exceptions. The library features adapters that convert throwing functions and asynchronous promises into typed result objects. This allows asynchronous rejections and unsafe code to be handled as explicit return values rather than uncaught exceptions. The framework covers a broad range of functional computation capabilities, in
Merges a list of outcomes into one result by either stopping at the first failure or gathering all errors.
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
Gathers outputs of multiple parallel tasks into a single unified structure after all complete.
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
Validates task results via a consensus process that replaces outputs if the judges disagree.
Allure is a test reporting framework that normalizes execution data from multiple test frameworks across different programming languages into a common intermediate format. It aggregates results from multiple sources into a shared directory of JSON files and generates self-contained HTML reports through a modular plugin pipeline. The architecture includes a hierarchical step tree model to represent test execution, metadata annotation injection to enrich results at runtime, and directory-watch incremental rendering that regenerates reports in real time as new data arrives. Unlike generic report
Collects raw test results from multiple sources into a shared directory of JSON files for unified processing.
NetExec is a framework for concurrent credential spraying and remote command execution across network protocols. It provides input sanitization and command parsing to reduce injection risks, a plugin-based protocol abstraction that dispatches credentials and commands uniformly regardless of transport, and session and token lifecycle management for long-running multi-command operations. Results from concurrent executions are collected and normalized through a result aggregation pipeline. The framework includes a concurrent job scheduler that manages worker threads for parallel execution across
Collects and normalises output from concurrent remote executions into a unified report with per-target status.
ROMA 是一个代理工作流引擎和递归任务编排器,旨在协调自主智能体执行复杂工作流。它作为一个多智能体框架,将高层目标分解为原子子任务,并通过依赖图管理其执行。 该系统的特点在于其分层规划-执行循环,能够递归分解目标并从叶节点任务向上合成结果。它通过原子任务隔离确保执行纯净度,为单个任务分配专用存储目录以防止数据干扰。 该平台涵盖了广泛的能力领域,包括跟踪执行轨迹和性能指标的智能体可观测性,以及使用沙盒代码和外部工具包的工具增强执行。它还提供了一个用于服务器管理编排和通过基于检查点的日志记录实现状态持久化的编程接口。
Aggregates outputs from leaf-node tasks upward through a decomposition tree to synthesize a coherent final answer.
Maestro is an autonomous task workflow engine that decomposes high-level goals into hierarchical sub-tasks and orchestrates their execution using multiple language model agents. It provides a unified interface for routing requests across different LLM providers, including proprietary models like Anthropic, OpenAI, and Gemini, as well as local models, enabling flexible provider selection and switching through a single entry point. The system distinguishes itself through its ability to generate complete software project structures directly on the host machine, creating directories and source fi
Reviews and consolidates outputs of all executed sub-tasks into a single cohesive final result using a powerful LLM.
coobjc 是一个 Objective-C 协程库,提供 await 方法和生成器,以简化 Objective-C 和 Swift 中的异步编程。它实现了非阻塞工作流,消除了嵌套回调和线程阻塞。 该工具包包括一个非阻塞 Foundation 包装器,可将同步的 Foundation 和 UIKit API 转换为可挂起的操作。它提供了一个用于通过 yield 按需生成值的惰性序列生成器,以及一个基于通道的通信工具,用于使用缓冲和非缓冲通道在并发任务之间交换数据。 该库涵盖了异步任务协调和状态管理,利用 Actor 模型防止数据竞争。其功能包括协程调度、取消,以及在不冻结用户界面的情况下执行文件系统和网络操作的能力。
Gathers outputs and errors from multiple asynchronous tasks into a single unified structure.
Botasaurus is a Python web scraping framework and headless browser automation system used to build scalable data extraction tools. It functions as a web data extraction tool and OCR document parser, converting website content, images, and PDF files into structured formats such as JSON, CSV, and Excel. The framework distinguishes itself by providing a scraper management interface that allows Python functions to be wrapped in a web-based UI or deployed as standalone desktop applications. This enables non-technical users to trigger extraction jobs and manage tasks via a graphical interface or RE
Combines outputs from multiple sub-tasks into a single consolidated result set for streamlined analysis.
This project is a promise-based concurrency framework and asynchronous task library for Swift and Objective-C. It functions as a workflow orchestrator that uses monadic transformations to chain operations and propagate results through a state machine. The library specializes in transforming traditional completion-handler APIs into promise-based structures to enable sequential execution. It provides mechanisms for coordinating simultaneous background processes, including the ability to aggregate results from multiple tasks or synchronize operations through racing and waiting. The framework co
Provides mechanisms to gather outputs and errors from multiple simultaneous asynchronous tasks into a single unified result.
coq_nvim is an asynchronous code completion engine for Neovim. It aggregates suggestions from multiple sources, including language servers, tag files, and local buffers, to provide non-blocking code completion. The engine distinguishes itself through a typo-resistant fuzzy completion filter and a two-stage weighted ranking system that prioritizes candidates based on recency and proximity. It utilizes an embedded SQLite database for local caching and background symbol indexing to accelerate lookups without freezing the editor interface. The project also includes a system for defining and expa
Gathers outputs from multiple asynchronous completion providers into a single unified structure without freezing the interface.
cppcoro is a C++ coroutine library and concurrency toolkit providing primitives for asynchronous tasks, lazy generators, and non-blocking execution. It functions as an asynchronous I/O framework for managing network sockets and file operations through an event loop. The library features a work-stealing thread pool for distributing tasks across multiple cores and a set of async generators for producing lazy sequences of values both synchronously and asynchronously. It includes a concurrency toolkit with async mutexes, latches, and shared tasks to coordinate multi-threaded execution. Its capab
Executes multiple asynchronous operations simultaneously and aggregates their results into a single collection.
CSharpFunctionalExtensions is a functional programming library for C# that provides a framework of monadic containers, pipeline orchestration tools, and immutable domain object patterns. It implements the result pattern to handle operation success and failure as values, reducing the reliance on exceptions for control flow. The library enables railway-oriented programming by chaining multiple operations into sequences that execute only upon the success of previous steps. It provides specialized wrappers for optional and result types to minimize null checks and nested conditional logic, alongsi
Aggregates multiple operation outcomes into a single unified result structure.
This project is a framework for building concurrent, event-driven applications in Ruby. It provides a core engine that orchestrates non-blocking input and output operations, allowing developers to handle high-volume network traffic and system tasks without the complexity of traditional callback-based programming. By leveraging lightweight fibers, the library enables cooperative multitasking that maintains responsiveness during heavy data processing workloads. The framework distinguishes itself through a structured concurrency model that organizes tasks into parent-child hierarchies. This appr
Allows execution flows to pause until asynchronous tasks complete and return results.