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

[radhikakundam]

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

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


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

commit dbc3302ef3bcbf3b90aef156f99348d9de70c897
Author: Disha Talreja <dishatalr...@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 <radhikakun...@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();