diff --git a/openpype/modules/ftrack/plugins/publish/integrate_ftrack_api.py b/openpype/modules/ftrack/plugins/publish/integrate_ftrack_api.py
index c4f7b1f05de..58591bacfd3 100644
--- a/openpype/modules/ftrack/plugins/publish/integrate_ftrack_api.py
+++ b/openpype/modules/ftrack/plugins/publish/integrate_ftrack_api.py
@@ -26,8 +26,6 @@ class IntegrateFtrackApi(pyblish.api.InstancePlugin):
     families = ["ftrack"]
 
     def process(self, instance):
-        session = instance.context.data["ftrackSession"]
-        context = instance.context
         component_list = instance.data.get("ftrackComponentsList")
         if not component_list:
             self.log.info(
@@ -36,8 +34,8 @@ def process(self, instance):
             )
             return
 
-        session = instance.context.data["ftrackSession"]
         context = instance.context
+        session = context.data["ftrackSession"]
 
         parent_entity = None
         default_asset_name = None
diff --git a/openpype/modules/ftrack/plugins/publish/integrate_ftrack_instances.py b/openpype/modules/ftrack/plugins/publish/integrate_ftrack_instances.py
index c8d9e4117d2..d937e647903 100644
--- a/openpype/modules/ftrack/plugins/publish/integrate_ftrack_instances.py
+++ b/openpype/modules/ftrack/plugins/publish/integrate_ftrack_instances.py
@@ -58,7 +58,7 @@ def process(self, instance):
         version_number = int(instance_version)
 
         family = instance.data["family"]
-        family_low = instance.data["family"].lower()
+        family_low = family.lower()
 
         asset_type = instance.data.get("ftrackFamily")
         if not asset_type and family_low in self.family_mapping:
@@ -140,24 +140,16 @@ def process(self, instance):
         first_thumbnail_component = None
         first_thumbnail_component_repre = None
         for repre in thumbnail_representations:
-            published_path = repre.get("published_path")
-            if not published_path:
-                comp_files = repre["files"]
-                if isinstance(comp_files, (tuple, list, set)):
-                    filename = comp_files[0]
-                else:
-                    filename = comp_files
-
-                published_path = os.path.join(
-                    repre["stagingDir"], filename
+            repre_path = self._get_repre_path(instance, repre, False)
+            if not repre_path:
+                self.log.warning(
+                    "Published path is not set and source was removed."
                 )
-                if not os.path.exists(published_path):
-                    continue
-                repre["published_path"] = published_path
+                continue
 
             # Create copy of base comp item and append it
             thumbnail_item = copy.deepcopy(base_component_item)
-            thumbnail_item["component_path"] = repre["published_path"]
+            thumbnail_item["component_path"] = repre_path
             thumbnail_item["component_data"] = {
                 "name": "thumbnail"
             }
@@ -216,6 +208,13 @@ def process(self, instance):
         extended_asset_name = ""
         multiple_reviewable = len(review_representations) > 1
         for repre in review_representations:
+            repre_path = self._get_repre_path(instance, repre, False)
+            if not repre_path:
+                self.log.warning(
+                    "Published path is not set and source was removed."
+                )
+                continue
+
             # Create copy of base comp item and append it
             review_item = copy.deepcopy(base_component_item)
 
@@ -270,7 +269,7 @@ def process(self, instance):
                 fps = instance_fps
 
             # Change location
-            review_item["component_path"] = repre["published_path"]
+            review_item["component_path"] = repre_path
             # Change component data
             review_item["component_data"] = {
                 # Default component name is "main".
@@ -327,7 +326,7 @@ def process(self, instance):
 
         # Add others representations as component
         for repre in other_representations:
-            published_path = repre.get("published_path")
+            published_path = self._get_repre_path(instance, repre, True)
             if not published_path:
                 continue
             # Create copy of base comp item and append it
@@ -360,6 +359,51 @@ def json_obj_parser(obj):
         ))
         instance.data["ftrackComponentsList"] = component_list
 
+    def _get_repre_path(self, instance, repre, only_published):
+        """Get representation path that can be used for integration.
+
+        When 'only_published' is set to true the validation of path is not
+        relevant. In that case we just need what is set in 'published_path'
+        as "reference". The reference is not used to get or upload the file but
+        for reference where the file was published.
+
+        Args:
+            instance (pyblish.Instance): Processed instance object. Used
+                for source of staging dir if representation does not have
+                filled it.
+            repre (dict): Representation on instance which could be and
+                could not be integrated with main integrator.
+            only_published (bool): Care only about published paths and
+                ignore if filepath is not existing anymore.
+
+        Returns:
+            str: Path to representation file.
+            None: Path is not filled or does not exists.
+        """
+
+        published_path = repre.get("published_path")
+        if published_path:
+            published_path = os.path.normpath(published_path)
+            if os.path.exists(published_path):
+                return published_path
+
+        if only_published:
+            return published_path
+
+        comp_files = repre["files"]
+        if isinstance(comp_files, (tuple, list, set)):
+            filename = comp_files[0]
+        else:
+            filename = comp_files
+
+        staging_dir = repre.get("stagingDir")
+        if not staging_dir:
+            staging_dir = instance.data["stagingDir"]
+        src_path = os.path.normpath(os.path.join(staging_dir, filename))
+        if os.path.exists(src_path):
+            return src_path
+        return None
+
     def _get_asset_version_status_name(self, instance):
         if not self.asset_versions_status_profiles:
             return None