Merge pull request #638 from data-integrations/metric-bug-fix

Fix bug in emitting metrics for only system directives
data-integrations · Apr 27, 2023 · ddf3059 · ddf3059
2 parents 372eed2 + a59a739
commit ddf3059
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java b/wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java
@@ -600,8 +600,8 @@ private Optional<ExpressionFactory<String>> getExpressionFactory(RelationalTranf
    */
   private void emitDirectiveMetrics(List<Directive> directives, Metrics metrics) throws DirectiveLoadException {
     for (Directive directive : directives) {
-      // skip emitting metrics if the directive is not system metric
-      if (registry.get(Contexts.SYSTEM, directive.define().getDirectiveName()) != null) {
+      // skip emitting metrics if the directive is not system directive
+      if (registry.get(Contexts.SYSTEM, directive.define().getDirectiveName()) == null) {
         continue;
       }
       List<EntityCountMetric> countMetrics = new ArrayList<>();