complete example

scaleoutsystems · Mar 11, 2024 · 58a5e11 · 58a5e11
1 parent 52e4b88
commit 58a5e11
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 21 deletions.
diff --git a/examples/async-simulation/requirements.txt b/examples/async-simulation/requirements.txt
@@ -1 +1,2 @@
-fire==0.3.1
+fire==0.3.1
+numpy
diff --git a/examples/load-test/.gitignore b/examples/load-test/.gitignore
@@ -2,5 +2,4 @@ data
 *.npz
 *.tgz
 *.tar.gz
-.async-simulation
 client.yaml
diff --git a/examples/load-test/docker-compose.override.yaml b/examples/load-test/docker-compose.override.yaml
diff --git a/examples/load-test/run_clients.py b/examples/load-test/run_clients.py
@@ -20,8 +20,7 @@
 
 DISCOVER_HOST = '127.0.0.1'
 DISCOVER_PORT = 8092
-N_CLIENTS = 5
-CLIENTS_AVAILABLE_TIME = 120
+N_CLIENTS = 3
 
 config = {'discover_host': DISCOVER_HOST, 'discover_port': DISCOVER_PORT, 'token': None, 'name': 'testclient',
           'client_id': 1, 'remote_compute_context': True, 'force_ssl': False, 'dry_run': False, 'secure': False,
@@ -53,7 +52,7 @@
     while not client.session_is_finished(session_config_fedavg['session_id']):
         time.sleep(1)
 
-    # Disconnect clients
-    time.sleep(CLIENTS_AVAILABLE_TIME)
+    print("Session ID: ", session_config_fedavg['session_id'])
+
     for client in clients:
         client.detach()