added underscore to function definition _parallel_client

Author: dantecn

OceanLab/utils.py

@@ -5,30 +5,7 @@
 import dask
 from dask.distributed import Client, progress
 
-##### Functions
-# =============================================================================
-# KERNEL FOR PARALLEL COMPUTING
-# =============================================================================
-def parallel_client(cpu_params=dict(tpw=2,nw=4,ml=7.5)):
-    """
-    Create client kernel for parallel computing
-    ====================================================
-    INPUT:
-        -> cpu_params: dict containing floats with keys
-            -> tpw: threads_per_worker
-            -> nw: n_workers
-            -> ml: memory_limit per worker [GB]
-    OUTPUT:
-        -> client: configuration of parallel computing
-    ====================================================
-    """
-
-    client = Client(threads_per_worker=cpu_params['tpw'], 
-                    n_workers=cpu_params['nw'], 
-                    memory_limit=str(cpu_params['ml'])+'GB')
-    return client
-#=============================================================================
-
+##### User functions
 #=============================================================================
 # NEAREST DISTANCE
 #=============================================================================
@@ -156,3 +133,30 @@ def timefilter(prop,filtdays=60):
 
     return m_prop,p_prop
 #=============================================================================
+
+##### Functions for relative imports
+# =============================================================================
+# KERNEL FOR PARALLEL COMPUTING
+# =============================================================================
+def _parallel_client(cpu_params=dict(tpw=2,nw=4,ml=7.5)):
+    """
+    Create client kernel for parallel computing
+    ====================================================
+    INPUT:
+        -> cpu_params: dict containing floats with keys
+            -> tpw: threads_per_worker
+            -> nw: n_workers
+            -> ml: memory_limit per worker [GB]
+    OUTPUT:
+        -> client: configuration of parallel computing
+    ====================================================
+    """
+
+    client = Client(threads_per_worker=cpu_params['tpw'], 
+                    n_workers=cpu_params['nw'], 
+                    memory_limit=str(cpu_params['ml'])+'GB')
+    return client
+#=============================================================================
+
+
+