Changeset 2689 for simo

Timestamp:

01/13/12 22:50:10 (4 months ago)

Author:

jussi

Message:

change: id_list handling for celery_runner

File:

• simo/trunk/src/celery_runner.py (modified) (1 diff)

simo/trunk/src/celery_runner.py

@@ -91 +91 @@
                                                           main_level,
                                                           distinct=True)
-            # TODO: this is still missing the id list option handling
             ids = [i[0] for i in ids]
-            ind_seq = runner_obj.cfg['simulation.index_sequence']
-            if ind_seq is not None:
+            id_list = runner_obj.cfg.get('simulation.id_list')
+            ind_seq = runner_obj.cfg.get('simulation.index_sequence')
+            if id_list:
+                ids = set(ids)
+                id_list = set(id_list)
+                ids = ids.intersection(id_list)
+            elif ind_seq is not None:
                 if ind_seq[1] is None:
                     ind_seq = (ind_seq[0], len(ids) + 1)