Changeset 34

Timestamp:

May 20, 2014 3:23:59 PM (10 years ago)

Author:

JohnLightfoot

Message:

various improvements

File:

• trunk/fiins.py (modified) (3 diffs)

trunk/fiins.py

@@ -2 +2 @@
 
 import collections
+import pp
 
 import beamsgenerator
@@ -20 +21 @@
         self.sky_sheet = sky_sheet
         self.result = collections.OrderedDict()
+
+        # start parallel python (pp), find the number of CPUS available
+        ppservers = ()
+        self.job_server = pp.Server(ppservers=ppservers)
+        print 'fiins starting pp with %s workers' % \
+          self.job_server.get_ncpus()
 
     def simulate(self):
@@ -54 +61 @@
         # calculate interferograms
         doublef = doublefourier.DoubleFourier(parameters=obs_specification,
-          previous_results=self.result)
+          previous_results=self.result, job_server=self.job_server)
         self.result['doublefourier'] = doublef.run()