Task #8475: Reenable auto mode for CEP4, but replace "CEP4:" hostnames with localhost

CEP/Pipeline/recipes/sip/bin/pulsar_pipeline.py

@@ -46,12 +46,24 @@ class pulsar_pipeline(control):
         dps = self.parset.makeSubset(
             self.parset.fullModuleName('DataProducts') + '.'
         )
+
+        def fix_locations(locations):
+            """ Hack to turn CEP4:/xxxx paths into valid host:path combinations. """
+
+            def fix(loc):
+              host,path = loc.split(':')
+              if host == "CEP4":
+                  host = "localhost"
+              return "%s:%s" % (host,path)
+
+            return [fix(loc) for loc in locations]
+
         # Coherent Stokes input data
         self.coherentStokesEnabled = dps.getBool('Input_CoherentStokes.enabled', False)
         self.input_data['coherent'] = DataMap([
             tuple(os.path.join(location, filename).split(':')) + (skip,)
                 for location, filename, skip in zip(
-                    dps.getStringVector('Input_CoherentStokes.locations'),
+                    fix_locations(dps.getStringVector('Input_CoherentStokes.locations')),
                     dps.getStringVector('Input_CoherentStokes.filenames'),
                     dps.getBoolVector('Input_CoherentStokes.skip'))
         ])
@@ -62,7 +74,7 @@ class pulsar_pipeline(control):
         self.input_data['incoherent'] = DataMap([
             tuple(os.path.join(location, filename).split(':')) + (skip,)
                 for location, filename, skip in zip(
-                    dps.getStringVector('Input_IncoherentStokes.locations'),
+                    fix_locations(dps.getStringVector('Input_IncoherentStokes.locations')),
                     dps.getStringVector('Input_IncoherentStokes.filenames'),
                     dps.getBoolVector('Input_IncoherentStokes.skip'))
         ])
@@ -71,7 +83,7 @@ class pulsar_pipeline(control):
         self.output_data['data'] = DataMap([
             tuple(os.path.join(location, filename).split(':')) + (skip,)
                 for location, filename, skip in zip(
-                    dps.getStringVector('Output_Pulsar.locations'),
+                    fix_locations(dps.getStringVector('Output_Pulsar.locations')),
                     dps.getStringVector('Output_Pulsar.filenames'),
                     dps.getBoolVector('Output_Pulsar.skip'))
         ])
@@ -146,7 +158,7 @@ class pulsar_pipeline(control):
         # Rebuilding sys.argv without the options given automatically by framework
         # --auto = automatic run from framework
         # -q = quiet mode, no user interaction
-        sys.argv = ['pulp.py', '-q']
+        sys.argv = ['pulp.py', '--auto', '-q']
 
         if self.globalfs:
           project = self.parset.getString(self.parset.fullModuleName('Campaign') + '.name')