daemon/pipeline.py

@@ -14,6 +14,7 @@ class Pipeline:
         self.logger     = logging.getLogger('play-daemon')
         self.queue      = config['daemon']['queue']
         self.storage    = config['daemon']['storage']
+        self.error      = config['daemon']['error']
         self.processing = config['daemon']['processing']
         self.notify_url = config['daemon']['notify_url']
         token           = config['daemon']['notify_token']
@@ -168,6 +169,7 @@ class Pipeline:
 
         # Delete queue file and upload data
         os.remove(os.path.join(self.queue, target_id))
+        os.remove(os.path.join(self.error, target_id))
         shutil.rmtree(package['base'])
         return