From searching the forum I can see that this error has come up a few times, but I haven't seen a fix that I can use yet. I have two parts of my code where I use pp, the first works fine, but the second time I use it I get the error:

[code]
Exception in thread run_local:
Traceback (most recent call last):
  File "/usr/lib/python2.6/threading.py", line 532, in __bootstrap_inner
    self.run()
  File "/usr/lib/python2.6/threading.py", line 484, in run
    self.__target(*self.__args, **self.__kwargs)
  File "/usr/local/lib/python2.6/dist-packages/pp-1.6.1-py2.6.egg/pp.py", line 721, in _run_local
    job.finalize(sresult)
UnboundLocalError: local variable 'sresult' referenced before assignment

           jobs = [(fninput, job_server.submit(
                    calculate_block,
                    (fninput,),
                    (),
                    ("numpy","scipy","sys"))) for fninput in fninputs]

   def _run_local(self,  job, sfunc, sargs, worker):
        """Runs a job locally"""
        sresult = None

        if self._exiting:
            return
        self.logger.info("Task %i started",  job.tid)

        start_time = time.time()

        try:
            worker.t.csend(sfunc)
            worker.t.send(sargs)
            sresult = worker.t.receive()
        except Exception as e:
            if self._exiting:
                return
            if SHOW_EXPECTED_EXCEPTIONS:
                self.logger.debug("Exception in _run_local (possibly expected)", exc_info=True)
                raise e

        job.finalize(sresult)

        # remove the job from the waiting list
        if self.__waittasks:
            self.__waittasks_lock.acquire()
            self.__waittasks.remove(job)
            self.__waittasks_lock.release()

        worker.free()

        self.__add_to_active_tasks(-1)
        if not self._exiting:
            self.__stat_add_time("local", time.time()-start_time)
        self.logger.debug("Task %i ended",  job.tid)
        self.__scheduler()

sresult=None

except

except Exception as e

RuntimeError: Communication pipe read error