Revert "testing new distr"

This reverts commit ccbba42.

fvgp/gp.py

@@ -19,8 +19,7 @@
 from loguru import logger
 from .mcmc import mcmc
 from hgdl.hgdl import HGDL
-#from .gp2Scale import gp2Scale as gp2S
-from .gp2ScaleR import gp2Scale as gp2S
+from .gp2Scale import gp2Scale as gp2S
 from dask.distributed import Variable
 from dask.distributed import Client
 from .sparse_matrix import gp2ScaleSparseMatrix

fvgp/gp2ScaleR.py

@@ -165,19 +165,7 @@ def _init_dask_client(self,dask_client):
         print("Scheduler Address: ", dask_client.scheduler_info()["address"])
         return dask_client, compute_worker_set,actor_worker
 
-    def submit_kernel_function(self, ij, hyperparameters, client):
-        i, j = ij
-        beg_i = i * self.batch_size
-        end_i = min((i+1) * self.batch_size, self.point_number)
-        beg_j = j * self.batch_size
-        end_j = min((j+1) * self.batch_size, self.point_number)
 
-        data = {"scattered_data": self.scatter_future, "hps": hyperparameters, "kernel": self.kernel,
-                "range_i": (beg_i, end_i), "range_j": (beg_j, end_j), "mode": "prior", "gpu": 0}
-
-        future = client.submit(kernel_function, data)
-
-        return future
 #########################################################################
 #########################################################################
 #########################################################################