diff --git a/pype/plugins/global/publish/collect_avalon_entities.py b/pype/plugins/global/publish/collect_avalon_entities.py
index c256dffd52..a429b3fc84 100644
--- a/pype/plugins/global/publish/collect_avalon_entities.py
+++ b/pype/plugins/global/publish/collect_avalon_entities.py
@@ -19,6 +19,7 @@ class CollectAvalonEntities(pyblish.api.ContextPlugin):
     label = "Collect Avalon Entities"
 
     def process(self, context):
+        io.install()
         project_name = api.Session["AVALON_PROJECT"]
         asset_name = api.Session["AVALON_ASSET"]
 
diff --git a/pype/plugins/global/publish/integrate_new.py b/pype/plugins/global/publish/integrate_new.py
index b5ad48526b..2a9b813231 100644
--- a/pype/plugins/global/publish/integrate_new.py
+++ b/pype/plugins/global/publish/integrate_new.py
@@ -111,15 +111,16 @@ class IntegrateAssetNew(pyblish.api.InstancePlugin):
 
         project_entity = instance.data["projectEntity"]
 
+        context_asset_name = context.data["assetEntity"]["name"]
+
         asset_name = instance.data["asset"]
         asset_entity = instance.data.get("assetEntity")
-        if not asset_entity:
+        if not asset_entity or asset_entity["name"] != context_asset_name:
             asset_entity = io.find_one({
                 "type": "asset",
                 "name": asset_name,
                 "parent": project_entity["_id"]
             })
-
             assert asset_entity, (
                 "No asset found by the name \"{0}\" in project \"{1}\""
             ).format(asset_name, project_entity["name"])
diff --git a/pype/plugins/global/publish/integrate_thumbnail.py b/pype/plugins/global/publish/integrate_thumbnail.py
index 1c4399b386..b623fa9072 100644
--- a/pype/plugins/global/publish/integrate_thumbnail.py
+++ b/pype/plugins/global/publish/integrate_thumbnail.py
@@ -137,3 +137,12 @@ class IntegrateThumbnails(pyblish.api.InstancePlugin):
         self.log.debug("Setting thumbnail for version \"{}\" <{}>".format(
             version["name"], str(version["_id"])
         ))
+
+        asset_entity = instance.data["assetEntity"]
+        io.update_many(
+            {"_id": asset_entity["_id"]},
+            {"$set": {"data.thumbnail_id": thumbnail_id}}
+        )
+        self.log.debug("Setting thumbnail for asset \"{}\" <{}>".format(
+            asset_entity["name"], str(version["_id"])
+        ))