Python library for developing data processing algorithms as computational graphs and their integration with publish-subscribe systems