This is an automated email from the ASF dual-hosted git repository.
potiuk 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 f5d8b0e796 Skip tests in DB isolation mode in
`tests/providers/amazon/aws/sensors/test_base_aws.py` (#41157)
f5d8b0e796 is described below
commit f5d8b0e79669f1364baff4760b13b063f8de0d17
Author: Vincent <[email protected]>
AuthorDate: Wed Jul 31 11:51:18 2024 -0400
Skip tests in DB isolation mode in
`tests/providers/amazon/aws/sensors/test_base_aws.py` (#41157)
---
tests/providers/amazon/aws/sensors/test_base_aws.py | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/tests/providers/amazon/aws/sensors/test_base_aws.py
b/tests/providers/amazon/aws/sensors/test_base_aws.py
index a080abf005..a10960585f 100644
--- a/tests/providers/amazon/aws/sensors/test_base_aws.py
+++ b/tests/providers/amazon/aws/sensors/test_base_aws.py
@@ -116,13 +116,14 @@ class TestAwsBaseSensor:
],
)
def test_execute(self, dag_maker, op_kwargs):
- with dag_maker("test_aws_base_sensor"):
+ with dag_maker("test_aws_base_sensor", serialized=True):
FakeDynamoDBSensor(task_id="fake-task-id", **op_kwargs,
poke_interval=1)
dagrun = dag_maker.create_dagrun(execution_date=timezone.utcnow())
tis = {ti.task_id: ti for ti in dagrun.task_instances}
tis["fake-task-id"].run()
+ @pytest.mark.skip_if_database_isolation_mode
@pytest.mark.parametrize(
"region, region_name",
[
@@ -180,6 +181,7 @@ class TestAwsBaseSensor:
with pytest.raises(AttributeError, match=error_match):
SoWrongSensor(task_id="fake-task-id")
+ @pytest.mark.skip_if_database_isolation_mode
@pytest.mark.parametrize(
"region, region_name, expected_region_name",
[
@@ -189,7 +191,7 @@ class TestAwsBaseSensor:
)
@pytest.mark.db_test
def test_region_in_partial_sensor(self, region, region_name,
expected_region_name, dag_maker):
- with dag_maker("test_region_in_partial_sensor"):
+ with dag_maker("test_region_in_partial_sensor", serialized=True):
FakeDynamoDBSensor.partial(
task_id="fake-task-id",
region=region,
@@ -203,9 +205,10 @@ class TestAwsBaseSensor:
ti.run()
assert ti.task.region_name == expected_region_name
+ @pytest.mark.skip_if_database_isolation_mode
@pytest.mark.db_test
def test_ambiguous_region_in_partial_sensor(self, dag_maker):
- with dag_maker("test_ambiguous_region_in_partial_sensor"):
+ with dag_maker("test_ambiguous_region_in_partial_sensor",
serialized=True):
FakeDynamoDBSensor.partial(
task_id="fake-task-id",
region="eu-west-1",
