diff --git a/pype/nuke/lib.py b/pype/nuke/lib.py
index 2f002ce130..4322e55c00 100644
--- a/pype/nuke/lib.py
+++ b/pype/nuke/lib.py
@@ -35,9 +35,9 @@ def writes_version_sync():
     for each in nuke.allNodes():
         if each.Class() == 'Write':
             avalon_knob_data = get_avalon_knob_data(each)
-            if avalon_knob_data['families'] not in ["render"]:
-                log.info(avalon_knob_data['families'])
-                continue
+            # if avalon_knob_data['families'] not in ["render"]:
+            #     log.info(avalon_knob_data['families'])
+            #     continue
             try:
                 node_file = each['file'].value()
                 log.info("node_file: {}".format(node_file))
diff --git a/pype/plugins/nuke/publish/extract_write_next_render.py b/pype/plugins/nuke/_load_unused/extract_write_next_render.py
similarity index 97%
rename from pype/plugins/nuke/publish/extract_write_next_render.py
rename to pype/plugins/nuke/_load_unused/extract_write_next_render.py
index d13e67a563..40bfe59ec2 100644
--- a/pype/plugins/nuke/publish/extract_write_next_render.py
+++ b/pype/plugins/nuke/_load_unused/extract_write_next_render.py
@@ -13,6 +13,7 @@ class WriteToRender(pyblish.api.InstancePlugin):
     families = ["write"]
 
     def process(self, instance):
+        return
         if [f for f in instance.data["families"]
                 if ".frames" in f]:
             instance[0]["render"].setValue(True)
diff --git a/pype/plugins/nuke/publish/collect_review.py b/pype/plugins/nuke/publish/collect_review.py
index 03f5437e86..c6a3173af1 100644
--- a/pype/plugins/nuke/publish/collect_review.py
+++ b/pype/plugins/nuke/publish/collect_review.py
@@ -14,14 +14,16 @@ class CollectReview(pyblish.api.InstancePlugin):
     family_targets = [".local", ".frames"]
 
     def process(self, instance):
+        pass
         families = [(f, search) for f in instance.data["families"]
                     for search in self.family_targets
                     if search in f][0]
 
         if families:
-            root_femilies = families[0].replace(families[1], "")
-            instance.data["families"].append(".".join([
-                root_femilies,
-                self.family
-            ]))
+            root_families = families[0].replace(families[1], "")
+            # instance.data["families"].append(".".join([
+            #     root_families,
+            #     self.family
+            # ]))
+            instance.data["families"].append("review")
             self.log.info("Review collected: `{}`".format(instance))
diff --git a/pype/plugins/nuke/publish/extract_review.py b/pype/plugins/nuke/publish/extract_review.py
index 9ff7097e61..cf0864e09d 100644
--- a/pype/plugins/nuke/publish/extract_review.py
+++ b/pype/plugins/nuke/publish/extract_review.py
@@ -2,6 +2,7 @@ import os
 import nuke
 import pyblish.api
 import pype
+from pype.vendor import ffmpeg
 
 
 class ExtractDataForReview(pype.api.Extractor):
@@ -12,27 +13,18 @@ class ExtractDataForReview(pype.api.Extractor):
     """
 
     order = pyblish.api.ExtractorOrder + 0.01
-    label = "Data for review"
+    label = "Extract Review"
     optional = True
 
-    families = ["write"]
+    families = ["review"]
     hosts = ["nuke"]
-    family_targets = [".local", ".review"]
 
     def process(self, instance):
 
-        families = [f for f in instance.data["families"]
-                    for search in self.family_targets
-                    if search in f]
-        if not families:
-            return
-        self.log.debug("here:")
         # Store selection
         selection = [i for i in nuke.allNodes() if i["selected"].getValue()]
-        self.log.debug("here:")
         # Deselect all nodes to prevent external connections
         [i["selected"].setValue(False) for i in nuke.allNodes()]
-        self.log.debug("here:")
         self.log.debug("creating staging dir:")
         self.staging_dir(instance)
 
@@ -55,32 +47,18 @@ class ExtractDataForReview(pype.api.Extractor):
 
         review_mov = os.path.join(staging_dir, file_name).replace("\\", "/")
 
-        if instance.data.get("baked_colorspace_movie"):
-            args = [
-                "ffmpeg", "-y",
-                "-i", instance.data["baked_colorspace_movie"],
-                "-pix_fmt", "yuv420p",
-                "-crf", "18",
-                "-timecode", "00:00:00:01",
-            ]
-
-        args.append(review_mov)
-
-        self.log.debug("Executing args: {0}".format(args))
-
         self.log.info("transcoding review mov: {0}".format(review_mov))
-        p = subprocess.Popen(
-            args,
-            stdout=subprocess.PIPE,
-            stderr=subprocess.STDOUT,
-            stdin=subprocess.PIPE,
-            cwd=os.path.dirname(args[-1])
-        )
+        if instance.data.get("baked_colorspace_movie"):
+            input_movie = instance.data["baked_colorspace_movie"]
+            out, err = (
+                ffmpeg
+                .input(input_movie)
+                .output(review_mov, pix_fmt='yuv420p', crf=18, timecode="00:00:00:01")
+                .overwrite_output()
+                .run()
+            )
 
-        output = p.communicate()[0]
 
-        if p.returncode != 0:
-            raise ValueError(output)
 
         self.log.debug("Removing `{0}`...".format(
             instance.data["baked_colorspace_movie"]))
@@ -101,12 +79,6 @@ class ExtractDataForReview(pype.api.Extractor):
 
         collection = instance.data.get("collection", None)
 
-        self.log.warning("instance.data['files']: {}".format(instance.data['files']))
-        if not collection:
-            collections, remainder = clique.assemble(*instance.data['files'])
-            collection = collections[0]
-            instance.data["collection"] = collection
-
         # Create nodes
         first_frame = min(collection.indexes)
         last_frame = max(collection.indexes)
@@ -156,6 +128,7 @@ class ExtractDataForReview(pype.api.Extractor):
         if representation in "mov":
             file = collection.format("{head}baked.mov")
             path = os.path.join(staging_dir, file).replace("\\", "/")
+            self.log.debug("Path: {}".format(path))
             instance.data["baked_colorspace_movie"] = path
             write_node["file"].setValue(path)
             write_node["file_type"].setValue("mov")