Feature - Added callback pluginProcessed

CONTRIBUTORS.txt

@@ -6,4 +6,5 @@ danielottosson2@gmail.com
 https://github.com/davidmartinezanim
 https://github.com/tokejepsen
 https://github.com/bigroy
-https://github.com/mkolar
+https://github.com/mkolar
+https://github.com/pscadding

pyblish/plugin.py

@@ -440,9 +440,12 @@ def process(plugin, context, instance=None, action=None):
     """
 
     if issubclass(plugin, (ContextPlugin, InstancePlugin)):
-        return __explicit_process(plugin, context, instance, action)
+        result = __explicit_process(plugin, context, instance, action)
     else:
-        return __implicit_process(plugin, context, instance, action)
+        result = __implicit_process(plugin, context, instance, action)
+
+    lib.emit("pluginProcessed", result=result)
+    return result
 
 
 def __explicit_process(plugin, context, instance=None, action=None):

tests/test_events.py

@@ -36,3 +36,80 @@ def on_validated(context):
     pyblish.util.validate()
 
     assert count["#"] == 1, count
+
+@with_setup(lib.setup_empty)
+def test_plugin_processed_event():
+    """pluginProcessed is emitted upon a plugin being processed, regardless of its success"""
+
+    class MyContextCollector(pyblish.api.ContextPlugin):
+        order = pyblish.api.CollectorOrder
+
+        def process(self, context):
+            context.create_instance("A")
+
+    class CheckInstancePass(pyblish.api.InstancePlugin):
+        order = pyblish.api.ValidatorOrder
+
+        def process(self, instance):
+            pass
+
+    class CheckInstanceFail(pyblish.api.InstancePlugin):
+        order = pyblish.api.ValidatorOrder
+
+        def process(self, instance):
+            raise Exception("Test Fail")
+
+    pyblish.api.register_plugin(MyContextCollector)
+    pyblish.api.register_plugin(CheckInstancePass)
+    pyblish.api.register_plugin(CheckInstanceFail)
+
+
+    count = {"#": 0}
+
+    def on_processed(result):
+        assert isinstance(result, dict)
+        count["#"] += 1
+
+    pyblish.api.register_callback("pluginProcessed", on_processed)
+    pyblish.util.publish()
+
+    assert count["#"] == 3, count
+
+@with_setup(lib.setup_empty)
+def test_plugin_failed_event():
+    """pluginFailed is emitted upon a plugin failing for any reason"""
+
+    class MyContextCollector(pyblish.api.ContextPlugin):
+        order = pyblish.api.CollectorOrder
+        def process(self, context):
+            context.create_instance("A")
+
+    class CheckInstancePass(pyblish.api.InstancePlugin):
+        order = pyblish.api.ValidatorOrder
+        def process(self, instance):
+            pass
+
+    class CheckInstanceFail(pyblish.api.InstancePlugin):
+        order = pyblish.api.ValidatorOrder
+        def process(self, instance):
+            raise Exception("Test Fail")
+
+    pyblish.api.register_plugin(MyContextCollector)
+    pyblish.api.register_plugin(CheckInstancePass)
+    pyblish.api.register_plugin(CheckInstanceFail)
+
+    count = {"#": 0}
+
+    def on_failed(plugin, context, instance, error):
+        #todo: add further checks for the other incoming args
+        #assert isinstance(instance, CheckInstanceFailRaise)
+        #assert isinstance(plugin, pyblish.api.InstancePlugin)
+        assert isinstance(context, pyblish.api.Context)
+        assert isinstance(error, Exception)
+
+        count["#"] += 1
+
+    pyblish.api.register_callback("pluginFailed", on_failed)
+    pyblish.util.publish()
+
+    assert count["#"] == 1, count