diff --git a/client/ayon_core/plugins/publish/collect_otio_subset_resources.py b/client/ayon_core/plugins/publish/collect_otio_subset_resources.py
index c142036b83..f7b1c9d9b2 100644
--- a/client/ayon_core/plugins/publish/collect_otio_subset_resources.py
+++ b/client/ayon_core/plugins/publish/collect_otio_subset_resources.py
@@ -149,6 +149,7 @@ def process(self, instance):
 
         self.log.info(
             "frame_start-frame_end: {}-{}".format(frame_start, frame_end))
+        review_repre = None
 
         if is_sequence:
             # file sequence way
@@ -177,6 +178,11 @@ def process(self, instance):
             repre = self._create_representation(
                 frame_start, frame_end, collection=collection)
 
+            if "review" in instance.data["families"]:
+                review_repre = self._create_representation(
+                frame_start, frame_end, collection=collection,
+                delete=True, review=True)
+
         else:
             _trim = False
             dirname, filename = os.path.split(media_ref.target_url)
@@ -191,17 +197,26 @@ def process(self, instance):
             repre = self._create_representation(
                 frame_start, frame_end, file=filename, trim=_trim)
 
+            if "review" in instance.data["families"]:
+                review_repre = self._create_representation(
+                frame_start, frame_end,
+                file=filename, delete=True, review=True)
+
         instance.data["originalDirname"] = self.staging_dir
 
+        # add representation to instance data
         if repre:
             colorspace = instance.data.get("colorspace")
             # add colorspace data to representation
             self.set_representation_colorspace(
                 repre, instance.context, colorspace)
 
-            # add representation to instance data
             instance.data["representations"].append(repre)
 
+        # add review representation to instance data
+        if review_repre:
+            instance.data["representations"].append(review_repre)            
+
         self.log.debug(instance.data)
 
     def _create_representation(self, start, end, **kwargs):
@@ -221,7 +236,8 @@ def _create_representation(self, start, end, **kwargs):
         representation_data = {
             "frameStart": start,
             "frameEnd": end,
-            "stagingDir": self.staging_dir
+            "stagingDir": self.staging_dir,
+            "tags": [],
         }
 
         if kwargs.get("collection"):
@@ -247,8 +263,10 @@ def _create_representation(self, start, end, **kwargs):
                 "frameEnd": end,
             })
 
-        if kwargs.get("trim") is True:
-            representation_data["tags"] = ["trim"]
+        for tag_name in ("trim", "delete", "review"):
+            if kwargs.get(tag_name) is True:
+                representation_data["tags"].append(tag_name)
+
         return representation_data
 
     def get_template_name(self, instance):