diff --git a/tendrl/commons/flows/import_cluster/__init__.py b/tendrl/commons/flows/import_cluster/__init__.py
index aadfcad3..f9e25a92 100644
--- a/tendrl/commons/flows/import_cluster/__init__.py
+++ b/tendrl/commons/flows/import_cluster/__init__.py
@@ -60,26 +60,6 @@ def run(self):
                     'Cluster.volume_profiling_flag']
                 _cluster.save()
 
-                # Try to claim "provisioner/:integration_id" tag
-                try:
-                    _tag = "provisioner/%s" % _cluster.integration_id
-                    _index_key = "/indexes/tags/%s" % _tag
-                    _node_id = json.dumps([NS.node_context.node_id])
-                    NS._int.wclient.write(_index_key, _node_id,
-                                          prevExist=False)
-                    # TODO(shtripat) ceph-installer is auto detected and
-                    #  provisioner/$integration_id
-                    # tag is set , below is not required for ceph
-                    current_tags = list(NS.node_context.tags)
-                    new_tags = ['provisioner/%s' % integration_id]
-                    new_tags += current_tags
-                    new_tags = list(set(new_tags))
-                    if new_tags != current_tags:
-                        NS.node_context.tags = new_tags
-                        NS.node_context.save()
-                except etcd.EtcdAlreadyExist:
-                    pass
-
         try:
             super(ImportCluster, self).run()
             _cluster = NS.tendrl.objects.Cluster(