Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions tests/models/test_mappedoperator.py
Original file line number Diff line number Diff line change
Expand Up @@ -1786,6 +1786,7 @@ def group(n: int) -> None:
assert states == expected


@pytest.mark.skip_if_database_isolation_mode # Does not work in db isolation mode
def test_mapped_tasks_in_mapped_task_group_waits_for_upstreams_to_complete(dag_maker, session):
"""Test that one failed trigger rule works well in mapped task group"""
with dag_maker() as dag:
Expand Down Expand Up @@ -1817,6 +1818,7 @@ def t3(a):
assert not ti3.state


@pytest.mark.skip_if_database_isolation_mode # Does not work in db isolation mode
def test_mapped_tasks_in_mapped_task_group_waits_for_upstreams_to_complete__mapped_skip_with_all_success(
dag_maker, session
):
Expand Down
2 changes: 2 additions & 0 deletions tests/models/test_skipmixin.py
Original file line number Diff line number Diff line change
Expand Up @@ -116,6 +116,7 @@ def test_skip_none_tasks(self):
assert not session.query.called
assert not session.commit.called

@pytest.mark.skip_if_database_isolation_mode # Does not work in db isolation mode
def test_skip_mapped_task(self, mock_session):
SkipMixin()._skip(
dag_run=MagicMock(spec=DagRun),
Expand All @@ -128,6 +129,7 @@ def test_skip_mapped_task(self, mock_session):
mock_session.execute.assert_not_called()
mock_session.commit.assert_not_called()

@pytest.mark.skip_if_database_isolation_mode # Does not work in db isolation mode
@patch("airflow.models.skipmixin.update")
def test_skip_none_mapped_task(self, mock_update, mock_session):
SkipMixin()._skip(
Expand Down
1 change: 1 addition & 0 deletions tests/models/test_taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -3768,6 +3768,7 @@ def test_echo_env_variables(self, dag_maker):
ti.refresh_from_db()
assert ti.state == State.SUCCESS

@pytest.mark.skip_if_database_isolation_mode # Does not work in db isolation mode, fails in context serialization
@pytest.mark.parametrize(
"code, expected_state",
[
Expand Down