diff --git a/MAC/Services/src/PipelineControl.py b/MAC/Services/src/PipelineControl.py
index 3146d9467f8d4d2971caec06603bc438a66545f4..987f5614dcea85ffdd90404fdda74f0ca2737a96 100755
--- a/MAC/Services/src/PipelineControl.py
+++ b/MAC/Services/src/PipelineControl.py
@@ -236,7 +236,7 @@ class PipelineDependencies(object):
     radb_task = self.rarpc.getTask(otdb_id=otdb_id)
 
     if radb_task is None:
-      raise TaskNotFoundException("otdb_id %s not found in RADB" % (otdb_id,))
+      raise PipelineDependencies.TaskNotFoundException("otdb_id %s not found in RADB" % (otdb_id,))
 
     predecessor_radb_ids = radb_task['predecessor_ids']
     predecessor_tasks = self.rarpc.getTasks(task_ids=predecessor_radb_ids)
@@ -253,7 +253,7 @@ class PipelineDependencies(object):
     radb_task = self.rarpc.getTask(otdb_id=otdb_id)
 
     if radb_task is None:
-      raise TaskNotFoundException("otdb_id %s not found in RADB" % (otdb_id,))
+      raise PipelineDependencies.TaskNotFoundException("otdb_id %s not found in RADB" % (otdb_id,))
 
     successor_radb_ids = radb_task['successor_ids']
     successor_tasks = self.rarpc.getTasks(task_ids=successor_radb_ids) if successor_radb_ids else []
@@ -272,11 +272,11 @@ class PipelineDependencies(object):
     try:
       myState = self.getState(otdbId)
       predecessorStates = self.getPredecessorStates(otdbId)
-    except TaskNotFoundException, e:
+    except PipelineDependencies.TaskNotFoundException, e:
       logger.error("canStart(%s): Error obtaining task states, not starting pipeline: %s", otdbId, e)
       return False
 
-    logger.debug("canStart(%s)? state = %s, predecessors = %s", otdbId, myState, predecessorStates)
+    logger.info("canStart(%s)? state = %s, predecessors = %s", otdbId, myState, predecessorStates)
 
     return (
       myState == "scheduled" and
@@ -481,7 +481,7 @@ class PipelineControl(OTDBBusListener):
     # to be cancelled as well.
 
     if not self.slurm.isQueuedOrRunning(otdbId):
-      logger.info("_stopPipeline: Job %s not running")
+      logger.info("_stopPipeline: Job %s not running", otdbId)
       return
 
     def cancel(jobName):