diff --git a/pype/plugins/nuke/publish/collect_legacy_write.py b/pype/plugins/nuke/publish/collect_legacy_write.py
new file mode 100644
index 0000000000..05dbe4216c
--- /dev/null
+++ b/pype/plugins/nuke/publish/collect_legacy_write.py
@@ -0,0 +1,25 @@
+import nuke
+
+import pyblish.api
+
+
+class CollectWriteLegacy(pyblish.api.ContextPlugin):
+    """Collect legacy write nodes."""
+
+    order = pyblish.api.CollectorOrder
+    label = "Collect Write Legacy"
+    hosts = ["nuke", "nukeassist"]
+
+    def process(self, context):
+
+        for node in nuke.allNodes():
+            if node.Class() != "Write":
+                continue
+
+            if "avalon" not in node.knobs().keys():
+                continue
+
+            instance = context.create_instance(
+                node.name(), family="write.legacy"
+            )
+            instance.append(node)
diff --git a/pype/plugins/nuke/publish/validate_write_legacy.py b/pype/plugins/nuke/publish/validate_write_legacy.py
new file mode 100644
index 0000000000..b452e60ba4
--- /dev/null
+++ b/pype/plugins/nuke/publish/validate_write_legacy.py
@@ -0,0 +1,62 @@
+import toml
+import os
+
+import nuke
+
+from avalon import api
+import pyblish.api
+
+
+class RepairWriteLegacyAction(pyblish.api.Action):
+
+    label = "Repair"
+    icon = "wrench"
+    on = "failed"
+
+    def process(self, context, plugin):
+
+        # Get the errored instances
+        failed = []
+        for result in context.data["results"]:
+            if (result["error"] is not None and result["instance"] is not None
+               and result["instance"] not in failed):
+                failed.append(result["instance"])
+
+        # Apply pyblish.logic to get the instances for the plug-in
+        instances = pyblish.api.instances_by_plugin(failed, plugin)
+
+        for instance in instances:
+            data = toml.loads(instance[0]["avalon"].value())
+            data["xpos"] = instance[0].xpos()
+            data["ypos"] = instance[0].ypos()
+            data["input"] = instance[0].input(0)
+            data["publish"] = instance[0]["publish"].value()
+            data["render"] = instance[0]["render"].value()
+            data["render_farm"] = instance[0]["render_farm"].value()
+
+            nuke.delete(instance[0])
+
+            family = "render{}".format(os.environ["AVALON_TASK"].capitalize())
+            api.create(data["subset"], data["asset"], family)
+            node = nuke.toNode(data["subset"])
+            node.setXYpos(data["xpos"], data["ypos"])
+            node.setInput(0, data["input"])
+            node["publish"].setValue(data["publish"])
+            node["render"].setValue(data["render"])
+            node["render_farm"].setValue(data["render_farm"])
+
+
+class ValidateWriteLegacy(pyblish.api.InstancePlugin):
+    """Validate legacy write nodes."""
+
+    order = pyblish.api.ValidatorOrder
+    optional = True
+    families = ["write.legacy"]
+    label = "Write Legacy"
+    hosts = ["nuke"]
+    actions = [RepairWriteLegacyAction]
+
+    def process(self, instance):
+
+        msg = "Clean up legacy write node \"{}\"".format(instance)
+        assert False, msg