249 ensemble instances not all running concurrently

examples-proposed/020-simple-ensemble/driver.py

@@ -55,11 +55,16 @@ def step(self, timestamp=0.0):
         # given set of variables.  E.g., the instance corresponding to
         # {'A' : 2, 'B' : 5.82, 'C' : 'baz'} is probably found in the
         # `INSTANCE_1` subdirectory.
+
+        # We also demonstrate that stdout and stderr output per instance can
+        # be captured in files by specifying logfile and errfile, respectively.
         mapping = self.services.run_ensemble(template, variables,
                                              run_dir=Path('.').absolute(),
                                              name='INSTANCE_',
                                              num_nodes=1,
-                                             cores_per_instance=1)
+                                             cores_per_instance=1,
+                                             logfile='stdout.txt',
+                                             errfile='stderr.txt')
         # Print each mapping of instance name to what variable values were used.
         for instance in mapping:
-            self.services.info(f'{instance!s}')
+            self.services.info(f'{instance!s}')

examples-proposed/020-simple-ensemble/ensemble.conf

@@ -1,7 +1,7 @@
 SIM_NAME = simpleensemble
 SIM_ROOT = $PWD/ENSEMBLES
 LOG_FILE = log
-LOG_LEVEL = INFO
+LOG_LEVEL = DEBUG
 SIMULATION_MODE = NORMAL
 
 [PORTS]

examples-proposed/020-simple-ensemble/instance_component.py

@@ -16,6 +16,8 @@ class InstanceComponent(Component):
     def step(self, timestamp: float = 0.0, **keywords):
         start = time()
 
+
+
         # ENSEMBLE_INSTANCE is a special IPS variable that contains the
         # string uniquely identifying this instance.  Each instance will have
         # the `run_ensemble()` `name` argument prepended to a unique number
@@ -24,6 +26,8 @@ def step(self, timestamp: float = 0.0, **keywords):
         self.services.info(f'{instance_id}: Start of step of instance '
                            f'component.')
 
+        print(f'start of instance component for {instance_id}')
+
         # Echo the parameters we're expecting, A, B, and C
         self.services.info(f'{instance_id}: instance component parameters: '
                            f'A={self.A}, B={self.B}, C={self.C}')
@@ -38,6 +42,7 @@ def step(self, timestamp: float = 0.0, **keywords):
             writer.writerow([instance_id, sys.argv[0], run_env['hostname'],
                              run_env['pid'], run_env['core_id'], start, time()])
 
+        print(f'Wrote stats.csv for {instance_id}')
 
         self.services.info(f'{instance_id}: End of step of instance '
                            f'component.')

examples-proposed/020-simple-ensemble/template.conf

@@ -1,7 +1,7 @@
 SIM_NAME = simpleensembleinstance
 SIM_ROOT = $PWD
 LOG_FILE = log
-LOG_LEVEL = INFO
+LOG_LEVEL = DEBUG
 SIMULATION_MODE = NORMAL
 
 [PORTS]