Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / erdos-project/erdos issues and pull requests

#241 - [Python] Implement __repr__ and __eq__ for Message

Pull Request - State: closed - Opened by pschafhalter about 2 years ago

#240 - [Bug] Fix import error for PyNodeHandle

Pull Request - State: closed - Opened by pschafhalter about 2 years ago

#239 - [Python] Add type checking via mypy

Pull Request - State: closed - Opened by sukritkalra about 2 years ago - 1 comment

#238 - Setup a Query subsystem between the Driver, Workers and Leader.

Pull Request - State: closed - Opened by sukritkalra about 2 years ago

#237 - Type Annotations for Operator.py

Pull Request - State: closed - Opened by HivaMohammadzadeh1 about 2 years ago

#236 - Leader-Worker Architecture.

Pull Request - State: closed - Opened by sukritkalra about 2 years ago

#235 - Update Rust Examples using new Graph API

Pull Request - State: closed - Opened by objorkman over 2 years ago

#234 - [Python] Add Graph API

Pull Request - State: closed - Opened by objorkman over 2 years ago

#233 - Expose Graph API to Drivers.

Pull Request - State: closed - Opened by objorkman over 2 years ago

#232 - [WIP] Control Plane for a Leader-Worker Architecture.

Pull Request - State: closed - Opened by sukritkalra over 2 years ago - 1 comment

#231 - Added type annotations to streams.py and message.py

Pull Request - State: closed - Opened by HivaMohammadzadeh1 over 2 years ago - 15 comments

#230 - [Bug] Fix deadlock in watermark callbacks

Pull Request - State: closed - Opened by objorkman over 2 years ago

#229 - [Bug] Fix watermark logic

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#227 - [Python] Update stream documentation

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#226 - [Bug] Enable cross-node streams to connect collocated operators

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#225 - [Python] Split streams by type

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#224 - [Python] Remove operators

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#223 - [Python] Expose ERDOS' LINQ API in Python

Pull Request - State: closed - Opened by sukritkalra over 2 years ago

#222 - Finish redesign for version 0.4.0

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#221 - Implement graphviz export of dataflow graph

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#220 - Update readme and documentation

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#219 - Cleanup APIs and examples

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#218 - [Cross Compile with Python]

Issue - State: closed - Opened by yuanhaorannnnnn over 2 years ago - 2 comments

#217 - [Python]can't find Rust compiler

Issue - State: closed - Opened by yuanhaorannnnnn over 2 years ago - 3 comments

#216 - Bump PyO3 version and fix CI

Pull Request - State: closed - Opened by sukritkalra over 2 years ago

#215 - [LINQ] Add timestamp join

Pull Request - State: closed - Opened by pschafhalter over 2 years ago - 2 comments

#214 - [CI] Fail on warnings when building Rust docs

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#213 - [CI] Enable Clippy linting and separate formatting checks.

Pull Request - State: closed - Opened by sukritkalra over 2 years ago

#212 - [Python] Support serializing message data before sending

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#210 - Replace YAPF with Black + isort in CI

Pull Request - State: closed - Opened by sukritkalra over 2 years ago - 3 comments

#209 - [CI] Fix Python build issues

Pull Request - State: closed - Opened by sukritkalra over 2 years ago

#208 - [Bug] Fix connect_two_in_one_out

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#207 - [Python] Update documentation

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#206 - [WIP][Python] Update documentation

Pull Request - State: closed - Opened by pschafhalter over 2 years ago - 1 comment

#205 - Reintroduce Stream trait, add PyStream base class

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#204 - [Python] Update docs for operators and streams

Pull Request - State: closed - Opened by objorkman over 2 years ago - 2 comments

#203 - Implement TimeVersionedState and clean up State API.

Pull Request - State: closed - Opened by sukritkalra over 2 years ago

#202 - [Python] Add LINQ API to streams

Pull Request - State: closed - Opened by sguduguntla over 2 years ago - 1 comment

#200 - Tests fail when ROS feature enabled

Issue - State: open - Opened by pschafhalter over 2 years ago

#199 - Fix doctests for ROS operators.

Pull Request - State: closed - Opened by sukritkalra over 2 years ago

#198 - Fix build issuse for M1 Macs

Pull Request - State: closed - Opened by objorkman over 2 years ago - 1 comment

#197 - [BUG] Fix pyo3 build issue in MacOS (#195)

Pull Request - State: closed - Opened by sukritkalra over 2 years ago - 2 comments

#196 - [LINQ] Add concat operator

Pull Request - State: closed - Opened by pschafhalter over 2 years ago - 1 comment

#195 - [MacOS] Python Build Fails

Issue - State: closed - Opened by sukritkalra over 2 years ago - 6 comments

#194 - Add OperatorConfig to operator run method

Pull Request - State: closed - Opened by objorkman over 2 years ago

#193 - [LINQ] Add example, and traits for filter, map, split

Pull Request - State: closed - Opened by sguduguntla over 2 years ago

#192 - Speed up CI

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#191 - Update and remove tests

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#190 - Add examples crate, ROS integration to CI

Pull Request - State: closed - Opened by objorkman over 2 years ago

#189 - Restructure project layout

Pull Request - State: closed - Opened by pschafhalter over 2 years ago

#188 - [Rust] Add ROS Operators

Pull Request - State: closed - Opened by objorkman almost 3 years ago - 1 comment

#187 - LINQ Operators

Pull Request - State: closed - Opened by sguduguntla almost 3 years ago - 4 comments

#186 - [Bug] Fix Python node configuration and remove slog

Pull Request - State: closed - Opened by pschafhalter almost 3 years ago

#185 - Switch logging to tracing from slog

Pull Request - State: closed - Opened by pschafhalter almost 3 years ago

#184 - [Bug] Fix possible deadlock in operator executors

Pull Request - State: closed - Opened by pschafhalter almost 3 years ago

#183 - [Python] Add name property and setter to Stream

Pull Request - State: closed - Opened by objorkman almost 3 years ago

#182 - [Python] Add ID property to ExtractStream, IngestStream

Pull Request - State: closed - Opened by objorkman almost 3 years ago

#181 - [Python] Add ID property to ReadStream, WriteStream

Pull Request - State: closed - Opened by objorkman almost 3 years ago

#180 - [Python] Add name setters and getters

Pull Request - State: closed - Opened by objorkman almost 3 years ago - 3 comments

#179 - [Bug] Fix bug with loops in dataflow

Pull Request - State: closed - Opened by pschafhalter almost 3 years ago

#178 - Fix cargo doc warnings and improve documentation

Pull Request - State: closed - Opened by pschafhalter almost 3 years ago

#177 - [Bug] Fix error when streams have no destination operators

Pull Request - State: closed - Opened by pschafhalter almost 3 years ago

#176 - [Python] Fix connect for IngestStream, LoopStream, and update examples

Pull Request - State: closed - Opened by objorkman almost 3 years ago - 1 comment

#175 - Update watermark example, Fix Timestamp bug

Pull Request - State: closed - Opened by objorkman almost 3 years ago - 2 comments

#174 - Update join streams example

Pull Request - State: closed - Opened by objorkman almost 3 years ago

#173 - Update simple pipeline example

Pull Request - State: closed - Opened by objorkman almost 3 years ago - 1 comment

#172 - Refactor graph and streams

Pull Request - State: closed - Opened by pschafhalter about 3 years ago

#171 - [WIP] Refactor Streams and Graphs

Pull Request - State: closed - Opened by pschafhalter about 3 years ago

#170 - Finished new redesigned MapOperator, FilterOperator, and SplitOperator

Pull Request - State: closed - Opened by sguduguntla about 3 years ago - 2 comments

#169 - Unable to pip install erdos==0.3.1

Issue - State: closed - Opened by armaangoel78 about 3 years ago - 2 comments

#168 - Implement Timestamp deadlines for TwoInMessageProcessor

Pull Request - State: closed - Opened by sukritkalra about 3 years ago - 1 comment

#167 - [WIP] Clean up Stream implementation

Pull Request - State: closed - Opened by pschafhalter about 3 years ago

#166 - Redesigned Python API

Pull Request - State: closed - Opened by sukritkalra about 3 years ago

#165 - Run IngestStreams and ExtractStreams on Node 0

Pull Request - State: closed - Opened by pschafhalter about 3 years ago

#164 - Upgrade tokio to 1.8.1

Pull Request - State: closed - Opened by pschafhalter about 3 years ago

#163 - Timestamp deadlines [WIP]

Pull Request - State: closed - Opened by sukritkalra about 3 years ago - 2 comments

#162 - Added more mostly internal code comments.

Pull Request - State: closed - Opened by ICGog about 3 years ago

#161 - Operator Redesign [WIP]

Pull Request - State: closed - Opened by sukritkalra about 3 years ago - 4 comments

#160 - Fault Tolerant basic pipeline

Pull Request - State: closed - Opened by sguduguntla over 3 years ago - 2 comments

#159 - Watermark callback with two input watermark streams doesn't seem to work

Issue - State: closed - Opened by sguduguntla over 3 years ago - 1 comment

#157 - Implement Timestamp Deadlines.

Pull Request - State: closed - Opened by sukritkalra over 3 years ago

#156 - Implement Worker

Pull Request - State: closed - Opened by pschafhalter over 3 years ago

#155 - Rewrite IntTimestamp to enum.

Pull Request - State: closed - Opened by sukritkalra over 3 years ago

#154 - Add OperatorStream struct and Stream trait

Pull Request - State: closed - Opened by pschafhalter over 3 years ago - 1 comment

#153 - Introduce MessageProcessorT and OperatorExecutorHelper abstractions.

Pull Request - State: closed - Opened by sukritkalra over 3 years ago

#152 - [Bugfix] Destroy operator when run finishes

Pull Request - State: closed - Opened by pschafhalter over 3 years ago

#151 - [Python] Add support for multimachine operators.

Pull Request - State: closed - Opened by shreyask23 over 3 years ago - 1 comment

#150 - Finished adding checkpoint and restore functionality to simple_pipeli…

Pull Request - State: closed - Opened by sguduguntla over 3 years ago - 1 comment

#149 - Events do not process when an operator is under high load

Issue - State: open - Opened by pschafhalter almost 4 years ago

#147 - [Python] Add erdos_to_ros operator with success and failure tests.

Pull Request - State: closed - Opened by shreyask23 almost 4 years ago - 2 comments

#146 - Implement try_read for PyExtractStream

Pull Request - State: closed - Opened by pschafhalter almost 4 years ago

#145 - Modify use of global dataflow graph for use with other executors

Pull Request - State: closed - Opened by pschafhalter almost 4 years ago

#143 - Release v0.3.1

Pull Request - State: closed - Opened by pschafhalter about 4 years ago

#139 - [BUG] Default to None if name of callback not available.

Pull Request - State: closed - Opened by sukritkalra about 4 years ago

#138 - Documentation and logging for Rust streams.

Pull Request - State: closed - Opened by sukritkalra about 4 years ago