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

amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new f2d4eef16cc Remove core imports in shared observability tests (#61784)
f2d4eef16cc is described below

commit f2d4eef16cc43d68908fd67c6632d8b97d4c3e63
Author: Amogh Desai <[email protected]>
AuthorDate: Thu Feb 12 12:28:06 2026 +0530

    Remove core imports in shared observability tests (#61784)
---
 .../tests/observability/metrics/test_stats.py      | 40 +++++++++++-----------
 1 file changed, 20 insertions(+), 20 deletions(-)

diff --git a/shared/observability/tests/observability/metrics/test_stats.py 
b/shared/observability/tests/observability/metrics/test_stats.py
index 110c36bddc4..98f5ef24d54 100644
--- a/shared/observability/tests/observability/metrics/test_stats.py
+++ b/shared/observability/tests/observability/metrics/test_stats.py
@@ -30,14 +30,13 @@ import statsd
 import airflow_shared
 import airflow_shared.observability.metrics.stats
 import airflow_shared.observability.metrics.validators
-from airflow._shared.configuration import AirflowConfigException
-from airflow._shared.observability.metrics.validators import (
-    PatternAllowListValidator,
-    PatternBlockListValidator,
-)
 from airflow_shared.observability.exceptions import InvalidStatsNameException
 from airflow_shared.observability.metrics.datadog_logger import 
SafeDogStatsdLogger
 from airflow_shared.observability.metrics.statsd_logger import SafeStatsdLogger
+from airflow_shared.observability.metrics.validators import (
+    PatternAllowListValidator,
+    PatternBlockListValidator,
+)
 
 from tests_common.test_utils.config import conf_vars
 from tests_common.test_utils.markers import 
skip_if_force_lowest_dependencies_marker
@@ -149,7 +148,8 @@ class TestStats:
                 "Your custom StatsD client must extend the statsd."
                 "StatsClient in order to ensure backwards compatibility."
             )
-            with pytest.raises(AirflowConfigException, match=error_message):
+            # we assert for Exception here instead of AirflowConfigException 
to not import from shared configuration
+            with pytest.raises(Exception, match=error_message):
                 
airflow_shared.observability.metrics.stats.Stats.incr("empty_key")
         importlib.reload(airflow_shared.observability.metrics.stats)
 
@@ -166,9 +166,9 @@ class TestStats:
                 is_statsd_on=True,
                 is_otel_on=False,
             )
-            assert (
-                
type(airflow_shared.observability.metrics.stats.Stats.metrics_validator)
-                is PatternAllowListValidator
+            assert isinstance(
+                
airflow_shared.observability.metrics.stats.Stats.metrics_validator,
+                PatternAllowListValidator,
             )
             assert 
airflow_shared.observability.metrics.stats.Stats.metrics_validator.validate_list
 == (
                 "name1",
@@ -190,9 +190,9 @@ class TestStats:
                 is_statsd_on=True,
                 is_otel_on=False,
             )
-            assert (
-                
type(airflow_shared.observability.metrics.stats.Stats.metrics_validator)
-                is PatternBlockListValidator
+            assert isinstance(
+                
airflow_shared.observability.metrics.stats.Stats.metrics_validator,
+                PatternBlockListValidator,
             )
             assert 
airflow_shared.observability.metrics.stats.Stats.metrics_validator.validate_list
 == (
                 "name1",
@@ -215,9 +215,9 @@ class TestStats:
                 is_statsd_on=True,
                 is_otel_on=False,
             )
-            assert (
-                
type(airflow_shared.observability.metrics.stats.Stats.metrics_validator)
-                is PatternAllowListValidator
+            assert isinstance(
+                
airflow_shared.observability.metrics.stats.Stats.metrics_validator,
+                PatternAllowListValidator,
             )
             assert 
airflow_shared.observability.metrics.stats.Stats.metrics_validator.validate_list
 == (
                 "name1",
@@ -438,8 +438,8 @@ class TestPatternValidatorConfigOption:
             )
 
             assert 
isinstance(airflow_shared.observability.metrics.stats.Stats.statsd, 
statsd.StatsClient)
-            assert (
-                
type(airflow_shared.observability.metrics.stats.Stats.instance.metrics_validator)
 is expected
+            assert isinstance(
+                
airflow_shared.observability.metrics.stats.Stats.instance.metrics_validator, 
expected
             )
 
     @conf_vars({**stats_on, **block_list, ("metrics", "metrics_allow_list"): 
"baz,qux"})
@@ -453,9 +453,9 @@ class TestPatternValidatorConfigOption:
             )
 
             assert 
isinstance(airflow_shared.observability.metrics.stats.Stats.statsd, 
statsd.StatsClient)
-            assert (
-                
type(airflow_shared.observability.metrics.stats.Stats.instance.metrics_validator)
-                is PatternAllowListValidator
+            assert isinstance(
+                
airflow_shared.observability.metrics.stats.Stats.instance.metrics_validator,
+                PatternAllowListValidator,
             )
             assert "Ignoring metrics_block_list" in caplog.text
 

Reply via email to