Python library for distributed AI processing pipelines, using swappable scheduler backends.

Support for several distributed backends: Ray, Dask, Spark. Major refactoring and API change.