add DistributedGroupByConsumer
adapt TransportExecutor to be able to create and run tasks dynamically

and streamlined the TAsk interface and usage
fixup! adapt TransportExecutor to be able to create and run tasks dynamically