robinhood / faust

Watch 135
Star 4.9k
Fork 400

Code
Issues 175
Pull requests 31
Actions
Projects
Security
Insights

Code
Issues
Pull requests
Actions
Projects
Security
Insights

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Pick a username

Email Address

Password

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

175 Open 213 Closed

Author

Filter by author

Label

Filter by label

Use alt + click/return to exclude labels.

Projects

Filter by project

Milestones

Filter by milestone

Assignee

Filter by who’s assigned

Sort

Sort by

Newest Oldest Most commented Least commented Recently updated Least recently updated

Most reactions

on_window_close of windowed table does not work well with group_by, when multiple workers

#662 opened Sep 29, 2020 by studynon 2 of 2

stream.take() function returns events() instead of values

#660 opened Sep 27, 2020 by itsmesrds

Allow accessing table data through `timedelta`

#659 opened Sep 25, 2020 by KPostOffice 2 of 2

`Exactly-once` semantics + rebalance crashes worker

#658 opened Sep 24, 2020 by g-clef 2 of 2

Can't use agent.test_context() for sink-less agents

#657 opened Sep 24, 2020 by agrenott 2 of 2

Last message in kafka is not getting processed with faust take() method

#656 opened Sep 23, 2020 by sivasai-quartic

Manually-created changlog topic doesn't allow iteration of keys in table with rocksdb

#654 opened Sep 22, 2020 by g-clef 2 of 2

How to compile faust.dsp integrating c++ code? Is it possible with Faust compiler 2.27 on Linux?

#653 opened Sep 22, 2020 by fewtubefx

Pip version of Faust is 1.10.4, whilst version on Github is 1.10.3

#651 opened Sep 17, 2020 by zerafachris

autodiscover does not actually log errors on discovery

#649 opened Sep 12, 2020 by jmaroeder 2 of 2

stream.take does not decrement events_active

#648 opened Sep 9, 2020 by jabonte

Memory leak in faust when there is nothing for the kafka consumer to do

#646 opened Sep 4, 2020 by jabonte

How to use app.monitor on_stream_event_in and on_stream_event_out (Sensors)

#645 opened Sep 3, 2020 by zaidyahya

Single handler for multiple topics

#644 opened Sep 3, 2020 by remy-sl

can we use faust without kafka?

#643 opened Aug 29, 2020 by loveJasmine

Json decore error confluent platform

#642 opened Aug 28, 2020 by bluebeel 2 of 2

[Quesiton] how to use table in docker

#641 opened Aug 27, 2020 by hackrole

Faust example for flask

#639 opened Aug 24, 2020 by sahilpaudel

The point of using concurrency on agents?

#637 opened Aug 21, 2020 by j4l-Shvn

Example for flask

#636 opened Aug 20, 2020 by sahilpaudel-pe

GPU Support in Faust

#635 opened Aug 20, 2020 by datametrician

is it possible to use Faust app stream without change log topic in kafka ?

#633 opened Aug 18, 2020 by abhisam

Is that safe to make "blocking" I/O calls from agents?

#631 opened Aug 11, 2020 by kshilov

Is faust still alive or it is abondoned?

#626 opened Aug 6, 2020 by Enacero

Offsets not commited due to duplicate in _acked

#625 opened Aug 4, 2020 by jabonte

Previous 1 2 3 4 5 6 7 Next

Previous Next

ProTip! Add no:assignee to see everything that’s not assigned.