python-streamz/streamz issues and pull requests

#480 - Combining the streamz.Stream.filenames() and streamz.Stream.from_textfile() using dask scatter?

Issue - State: open - Opened by ayanb07 9 days ago

#479 - Compile the code into c++

Issue - State: open - Opened by River-Shi 4 months ago - 1 comment

#478 - Suggestions for improving code performance

Issue - State: open - Opened by River-Shi 5 months ago - 6 comments

#477 - remove six dependency

Pull Request - State: closed - Opened by a-detiste 8 months ago - 7 comments

#476 - Is streamz not maintained anymore? What happened to cuStreamz?

Issue - State: open - Opened by Daniel451 10 months ago - 10 comments

#475 - Parallel streams with buffers

Issue - State: open - Opened by john-jam 11 months ago - 3 comments

#474 - Streamz with websocket not steaming any data

Issue - State: open - Opened by leahpence about 1 year ago - 5 comments

#473 - streamz's typing system can't work properly in vscode

Issue - State: open - Opened by ghost over 1 year ago - 2 comments

#472 - Streamz hvplot resets zoom and pan on each update

Issue - State: open - Opened by josephwinston over 1 year ago - 4 comments

#471 - Add pytest fixture to clean up the IO loop

Issue - State: open - Opened by 0x26res over 1 year ago - 4 comments

#470 - Hello from LorryStream and Kotori / Streamz is cool

Issue - State: open - Opened by amotl over 1 year ago - 2 comments

#469 - Quickstart lacks conda/environments/streamz_dev.yml

Issue - State: open - Opened by gdmcbain over 1 year ago - 6 comments

#468 - Collect does not allow awaitable sinks

Issue - State: open - Opened by arunaruljothi almost 2 years ago

#467 - Streamz not working in Jupyterlite

Issue - State: open - Opened by MarcSkovMadsen about 2 years ago

#466 - Time based lookback window?

Issue - State: open - Opened by dirtyValera about 2 years ago - 1 comment

#465 - Is it possible to use event time/syntethic time rather than system time?

Issue - State: open - Opened by dirtyValera about 2 years ago - 2 comments

#464 - visualizing streams and changing variables during runtime

Issue - State: open - Opened by OpenCoderX about 2 years ago - 5 comments

#463 - Fix #462 flattening of iterators without len

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

#462 - flatten doesn't work with iterables without defined length

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

#461 - AttributeError: 'Output' object has no attribute '_ipython_display_'

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

#460 - Dropping `pkg_resources`

Issue - State: open - Opened by jakirkham about 2 years ago

#460 - Dropping `pkg_resources`

Issue - State: open - Opened by jakirkham about 2 years ago

#459 - Dynamically add upstreams to zip

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

#459 - Dynamically add upstreams to zip

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

#458 - handle username and pw for mqtt source

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

#458 - handle username and pw for mqtt source

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

#457 - Passing Username and Password to from_mqtt()

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

#457 - Passing Username and Password to from_mqtt()

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

#456 - How to parametrize stream/pipeline creation?

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

#455 - CI fixes

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

#454 - Show streamz.DataFrame in notebook with ipywidgets>8

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

#453 - missing positional argument: 'topic' in to_mqtt

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

#452 - How to load initial state or backfill the stream dataframe

Issue - State: open - Opened by demiladef over 2 years ago - 2 comments

#452 - How to load initial state or backfill the stream dataframe

Issue - State: open - Opened by demiladef over 2 years ago - 2 comments

#451 - How to store information from PeriodicDataFrame

Issue - State: open - Opened by rebeckaflynn1 over 2 years ago - 1 comment

#451 - How to store information from PeriodicDataFrame

Issue - State: open - Opened by rebeckaflynn1 over 2 years ago - 1 comment

#450 - Gracefully exit python script using Streams

Issue - State: open - Opened by arjun180 almost 3 years ago - 1 comment

#450 - Gracefully exit python script using Streams

Issue - State: open - Opened by arjun180 almost 3 years ago - 1 comment

#449 - Streamz/Dask: gather does not wait for all results of buffer

Issue - State: open - Opened by liusztc09 almost 3 years ago

#448 - Transfer to notebook

Pull Request - State: open - Opened by martindurant about 3 years ago - 1 comment

#447 - Can a stream emit two messages for each one received?

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

#446 - RiverML: update the plots less frequently

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

#445 - Add Stream node constructor for sub-classing #442

Pull Request - State: open - Opened by florentbr about 3 years ago - 7 comments

#444 - River nodes in an async context were not returning awaitable

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

#443 - Fix Stream subclassing

Pull Request - State: closed - Opened by florentbr about 3 years ago - 5 comments

#442 - Fail to extend a Stream with new methods

Issue - State: open - Opened by florentbr about 3 years ago - 6 comments

#441 - Update core.rst `_global_sinks` path

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

#440 - Increase the usage of augmented assignment statements

Issue - State: open - Opened by elfring about 3 years ago

#439 - `test_dask.py` fails to import with `distributed` 2021.10.0

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

#438 - Fixes issue 431 for kafka oauth source

Pull Request - State: closed - Opened by prodo56 over 3 years ago - 6 comments

#437 - websocket integration

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

#437 - websocket integration

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

#436 - bump for release

Pull Request - State: closed - Opened by martindurant over 3 years ago - 5 comments

#435 - 0.6.3 Release

Issue - State: closed - Opened by quasiben over 3 years ago

#434 - Add River nodes and examples

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

#433 - Generic exception handling

Pull Request - State: open - Opened by freol35241 over 3 years ago - 11 comments

#432 - Integrate with River

Issue - State: open - Opened by martindurant over 3 years ago

#431 - from_kafka doesn't work with oauth based authentication

Issue - State: closed - Opened by pthalasta over 3 years ago - 5 comments

#430 - Streamz aggregations fail with TypeError

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

#429 - Simple example of stream with Asyncio operations

Issue - State: open - Opened by massyah over 3 years ago - 2 comments

#428 - Does Streamz support modin/vaex/koalas?

Issue - State: open - Opened by enthusiastics over 3 years ago - 1 comment

#427 - Using partition "breaks" program logic

Issue - State: open - Opened by scherand over 3 years ago - 2 comments

#426 - fix dask import

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

#426 - fix dask import

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

#425 - Cannot use latest versions of dask, dask distributed.

Issue - State: closed - Opened by stefanopalmieri over 3 years ago

#424 - Execution terminates early with Dask.distributed

Issue - State: closed - Opened by WilliamCVan over 3 years ago - 4 comments

#424 - Execution terminates early with Dask.distributed

Issue - State: closed - Opened by WilliamCVan over 3 years ago - 4 comments

#423 - Fix `apply` import from `dask`

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

#423 - Fix `apply` import from `dask`

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

#422 - Sink to a Web Socket server?

Issue - State: closed - Opened by gamesbook over 3 years ago - 6 comments

#422 - Sink to a Web Socket server?

Issue - State: closed - Opened by gamesbook over 3 years ago - 6 comments

#421 - Accumulate example not running?

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

#420 - MQTT as a first-class Source?

Issue - State: closed - Opened by gamesbook over 3 years ago - 5 comments

#420 - MQTT as a first-class Source?

Issue - State: closed - Opened by gamesbook over 3 years ago - 5 comments

#419 - Speed tests with a Stream?

Issue - State: open - Opened by gamesbook over 3 years ago - 5 comments

#418 - Allow example for dataframe to not be a dataframe

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

#417 - Accumulate without emit/output

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

#416 - How to access metadata in downstream functions?

Issue - State: closed - Opened by scherand almost 4 years ago - 4 comments

#415 - Real tail of stream (last n elements)

Issue - State: open - Opened by JulianWgs almost 4 years ago - 3 comments

#414 - Adding map streams iteratively using a local lambda parametrized by the iterate value masks all previous iterations with final one

Issue - State: closed - Opened by taylorm0192 almost 4 years ago - 2 comments

#413 - dask summit talk?

Issue - State: closed - Opened by martindurant almost 4 years ago - 6 comments

#412 - Add Expanding and EWM.mean

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

#411 - Display in notebook without ipywidgets

Pull Request - State: closed - Opened by martindurant almost 4 years ago - 6 comments

#410 - Informative repr for streamz when ipywidgets is not installed

Issue - State: closed - Opened by mrocklin almost 4 years ago - 2 comments

#409 - a logo for streamz?

Issue - State: open - Opened by martindurant almost 4 years ago - 4 comments

#408 - Attempting to plot DataFrame causes stream to stop updating

Issue - State: closed - Opened by ErstBlack about 4 years ago - 3 comments

#407 - FEATURE: user events

Issue - State: closed - Opened by martindurant about 4 years ago - 4 comments

#406 - release 0.6.2

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

#405 - Release?

Issue - State: closed - Opened by martindurant about 4 years ago

#404 - Pieces that occurred while working on intake-streamz

Pull Request - State: closed - Opened by martindurant about 4 years ago - 5 comments

#403 - remove travis

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

#402 - migrate to github actions

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

#401 - Test showing synchronous partition(timeout) + dask scatter is broken

Pull Request - State: closed - Opened by wwoods about 4 years ago - 9 comments

#401 - Test showing synchronous partition(timeout) + dask scatter is broken

Pull Request - State: closed - Opened by wwoods about 4 years ago - 9 comments

#400 - Test showing RefCounter is broken on master

Pull Request - State: closed - Opened by wwoods about 4 years ago - 2 comments

#399 - Fix for #394 #397 - non-unique values with scatter

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

#399 - Fix for #394 #397 - non-unique values with scatter

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

GitHub / python-streamz/streamz issues and pull requests