diff --git a/lib/cluster/services/cluster.js b/lib/cluster/services/cluster.js
index <HASH>..<HASH> 100644
--- a/lib/cluster/services/cluster.js
+++ b/lib/cluster/services/cluster.js
@@ -28,11 +28,13 @@ module.exports = function(context, server) {
         socket.on('slicer:job_finished', function(data) {
             //remove any pending worker request on completed jobs
             pendingWorkerRequests.remove(data.job_id);
-            event.emit('cluster:job_finished', data.job_id);
             io.emit('cluster_service:stop_job', {job_id: data.job_id});
             //if errors in slices, emit error event
             if (data.errors.length > 0) {
-                event.emit('slicer:slice_failure', data)
+                event.emit('slicer:slice_failure', data.job_id)
+            }
+            else{
+                event.emit('cluster:job_finished', data.job_id);
             }
         });
completed event does not overide failed event