diff --git a/pype/plugins/global/publish/validate_ffmpeg_installed.py b/pype/plugins/global/publish/validate_ffmpeg_installed.py
index f6738e6de1..61127ff96e 100644
--- a/pype/plugins/global/publish/validate_ffmpeg_installed.py
+++ b/pype/plugins/global/publish/validate_ffmpeg_installed.py
@@ -8,12 +8,11 @@ except ImportError:
     import errno
 
 
-class ValidateFFmpegInstalled(pyblish.api.Validator):
+class ValidateFFmpegInstalled(pyblish.api.ContextPlugin):
     """Validate availability of ffmpeg tool in PATH"""
 
     order = pyblish.api.ValidatorOrder
     label = 'Validate ffmpeg installation'
-    families = ['review']
     optional = True
 
     def is_tool(self, name):
@@ -27,7 +26,7 @@ class ValidateFFmpegInstalled(pyblish.api.Validator):
                 return False
         return True
 
-    def process(self, instance):
+    def process(self, context):
         ffmpeg_path = pype.lib.get_ffmpeg_tool_path("ffmpeg")
         self.log.info("ffmpeg path: `{}`".format(ffmpeg_path))
         if self.is_tool(ffmpeg_path) is False:
diff --git a/pype/tools/pyblish_pype/control.py b/pype/tools/pyblish_pype/control.py
index aa39663182..a078f0146d 100644
--- a/pype/tools/pyblish_pype/control.py
+++ b/pype/tools/pyblish_pype/control.py
@@ -307,6 +307,11 @@ class Controller(QtCore.QObject):
                             "%s was inactive, skipping.." % instance
                         )
                         continue
+                    # Stop if was stopped
+                    if self.stopped:
+                        self.stopped = False
+                        yield IterationBreak("Stopped")
+
                     yield (plugin, instance)
             else:
                 families = util.collect_families_from_instances(