diff --git a/examples/run_og_usa.py b/examples/run_og_usa.py
index 1a56e9af..5343db51 100644
--- a/examples/run_og_usa.py
+++ b/examples/run_og_usa.py
@@ -14,8 +14,8 @@
 
 def main():
     # Define parameters to use for multiprocessing
-    client = Client()
     num_workers = min(multiprocessing.cpu_count(), 7)
+    client = Client(n_workers=num_workers)
     print("Number of workers = ", num_workers)
 
     # Directories to save data