mars-project / mars / 73

93%

push

travis-ci

Add pseudo-cluster mode support (#35)

* remove root distributor, add SchedulerDistributor and WorkerDistributor

* move the start_service logic in scheduler main to a sole file

* add missing file

* add worker service

* unify worker actor names(with prefix w:)

* add localDistributedCluster, fix test_api

* add local cluster session

* fix dashboard

* add web suppport

* ajust the way to calculate number of workers and schedulers, add ut for it

* fix fetch tensor when the result tensor is a scalar, fix tensor.execute that not every session supports n_parallel, add ut for local cluster execute

* fix session when the result is an scalar and not a numpy type

* add mechanism to check if scheduler is ready to prevent failing of prepare graph

* use actor pool's sleep instead of time.sleep

* limit shared memory size for testing local cluster

4333 of 6042 branches covered (71.71%)

Branch coverage included in aggregate %.

18117 of 20957 relevant lines covered (86.45%)

6.87 hits per line