[atlas] branch master updated: ATLAS-4674 - Regression: Classification tagging is not sending appropriate notification to ATLAS_ENTITIES

[ra...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

radhikakundam pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/master by this push:
     new 17c78bac3 ATLAS-4674 - Regression: Classification tagging is not sending appropriate notification to ATLAS_ENTITIES
17c78bac3 is described below

commit 17c78bac3bfd9c8e7c12548b044b9d747704a973
Author: Disha Talreja <di...@cloudera.com>
AuthorDate: Tue Oct 18 12:55:10 2022 -0700

    ATLAS-4674 - Regression: Classification tagging is not sending appropriate notification to ATLAS_ENTITIES
    
    Signed-off-by: radhikakundam <ra...@apache.org>
---
 .../atlas/repository/store/graph/v2/tasks/ClassificationTask.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationTask.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationTask.java
index 74bed571f..6565bda38 100644
--- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationTask.java
+++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/tasks/ClassificationTask.java
@@ -74,6 +74,7 @@ public abstract class ClassificationTask extends AbstractTask {
 
     @Override
     public AtlasTask.Status perform() throws Exception {
+        RequestContext.clear();
         Map<String, Object> params = getTaskDef().getParameters();
 
         if (MapUtils.isEmpty(params)) {
@@ -104,6 +105,7 @@ public abstract class ClassificationTask extends AbstractTask {
             throw e;
         } finally {
             graph.commit();
+            RequestContext.clear();
         }
 
         return getStatus();