Bugfix for py32 and above
Fixed pubsub to work in cluster mode
More refactoring, WIP, most stuff now works, except pipelines