diff --git a/run_examples/run_ogcore_example.py b/run_examples/run_ogcore_example.py
index 878da9e2b..d905b3bfc 100644
--- a/run_examples/run_ogcore_example.py
+++ b/run_examples/run_ogcore_example.py
@@ -25,9 +25,9 @@
 
 def main():
     # Define parameters to use for multiprocessing
-    client = Client()
     num_workers = min(multiprocessing.cpu_count(), 7)
     print("Number of workers = ", num_workers)
+    client = Client(n_workers=num_workers)
     run_start_time = time.time()
 
     # Directories to save data