Redis + bytewax Run listener/publisher scripts and a redis container docker-compose up echo bytewax dataflow python -m bytewax.run src/redis_dataflow_echo:flow