Removed debugging print statements

Author: pintohutch

nipype/pipeline/plugins/base.py

@@ -241,7 +241,6 @@ def run(self, graph, config, updatehash=False):
                             notrun.append(self._clean_queue(jobid, graph,
                                                             result=result))
                         else:
-                            print "DJC: Calling task finished for %s cb from DistributedPluginBase.run"%(str(taskid))
                             self._task_finished_cb(jobid, result)
                             self._remove_node_dirs()
                         self._clear_task(taskid)
@@ -380,7 +379,6 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
                                  )
                                ):
                                 continue_with_submission = False
-                                print "DJC: Calling task finised cb from DistributedPluginBase._send_procs_to_workers hash==true"
                                 self._task_finished_cb(jobid)
                                 self._remove_node_dirs()
                         except Exception:
@@ -397,7 +395,6 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
                                 self.procs[jobid].run()
                             except Exception:
                                 self._clean_queue(jobid, graph)
-                            print "DJC: Calling task finised cb from DistributedPluginBase._send_procs_to_workers continue_with_submission==true"
                             self._task_finished_cb(jobid)
                             self._remove_node_dirs()
                         else:
@@ -422,10 +419,7 @@ def _task_finished_cb(self, jobid, result=None):
             if result == None:
                 if self._taskresult.has_key(jobid):
                     result = self._taskresult[jobid].get()
-                    print 'MMMM'
-                    print result['real_memory'], result['real_memory2']
                 else:
-                    print "DJC: %s not found, taskresult keys are: %s"%(str(jobid),":".join([str(k) for k in self._taskresult.keys()]))
                     result = {'real_memory' : 'nokey'}
             self._status_callback(self.procs[jobid], 'end', result)
         # Update job and worker queues