old_contents: # BEGIN_COPYRIGHT
  # 
  # Copyright 2012 CRS4.
  # 
  # Licensed under the Apache License, Version 2.0 (the "License"); you may not
  # use this file except in compliance with the License. You may obtain a copy
  # of the License at
  # 
  #   http://www.apache.org/licenses/LICENSE-2.0
  # 
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  # License for the specific language governing permissions and limitations
  # under the License.
  # 
  # END_COPYRIGHT
  
  """
  Support module for running pydoop script examples.
  """
  
  import os, subprocess as sp
  import pydoop.hadut as hadut
  import pydoop.test_support as pts
  
  
  PYDOOP_EXE = "../../scripts/pydoop"
  PREFIX = os.getenv("PREFIX", pts.get_wd_prefix())
  
  
  class PydoopScriptRunner(hadut.PipesRunner):
  
    BASE_ARGS = [PYDOOP_EXE, "script"]
  
    def __init__(self, logger=None):
      super(PydoopScriptRunner, self).__init__(prefix=PREFIX, logger=logger)
  
    def run(self, script, more_args=None):
      args = self.BASE_ARGS + [script, self.input, self.output]
      self.logger.info("running pydoop script")
      retcode = sp.call(args + (more_args or []))
      if retcode:
        raise RuntimeError("Error running pydoop_script")
  
new_contents: # BEGIN_COPYRIGHT
  # 
  # Copyright 2012 CRS4.
  # 
  # Licensed under the Apache License, Version 2.0 (the "License"); you may not
  # use this file except in compliance with the License. You may obtain a copy
  # of the License at
  # 
  #   http://www.apache.org/licenses/LICENSE-2.0
  # 
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  # License for the specific language governing permissions and limitations
  # under the License.
  # 
  # END_COPYRIGHT
  
  """
  Support module for running pydoop script examples.
  """
  
  import os, subprocess as sp
  import pydoop.hadut as hadut
  import pydoop.test_support as pts
  
  
  PYDOOP_EXE = os.path.join(os.path.dirname(__file__), "../../scripts/pydoop")
  PREFIX = os.getenv("PREFIX", pts.get_wd_prefix())
  
  
  class PydoopScriptRunner(hadut.PipesRunner):
  
    BASE_ARGS = [PYDOOP_EXE, "script"]
  
    def __init__(self, logger=None):
      super(PydoopScriptRunner, self).__init__(prefix=PREFIX, logger=logger)
  
    def run(self, script, more_args=None):
      args = self.BASE_ARGS + [script, self.input, self.output]
      self.logger.info("running pydoop script")
      retcode = sp.call(args + (more_args or []))
      if retcode:
        raise RuntimeError("Error running pydoop_script")
  
subject: Make pydoop path relative to file rather than CWD