bytewax.run

Executing dataflows and the Bytewax runtime.

Dataflows are run for local development or production by executing this module as as script with python -m bytewax.run.

See python -m bytewax.run --help for more info.

If you need to execute a dataflow as part of running unit tests, see bytewax.testing.

Functions

cli_main(

flow,

*,

workers_per_process=1,

process_id=None,

addresses=None,

epoch_interval=None,

recovery_config=None,

)