Skip to content
Merged
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
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,6 @@
from airflow.utils import timezone

# The tests do not create dag runs, so db isolation tests are skipped
pytestmark = pytest.mark.db_test


DEFAULT_DATE = timezone.datetime(2015, 1, 1)
TEST_DAG_ID = "unit_test_dag"
Expand All @@ -52,6 +50,7 @@ def setup_connections(self, create_connection_without_db):
self.dag = dag
create_connection_without_db(Connection(conn_id="asana_test", conn_type="asana", password="test"))

@pytest.mark.db_test
@patch("airflow.providers.asana.hooks.asana.TasksApi", autospec=True, return_value=asana_tasks_api_mock)
def test_asana_create_task_operator(self, mock_tasks_api):
"""
Expand All @@ -69,6 +68,7 @@ def test_asana_create_task_operator(self, mock_tasks_api):
create_task.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)
assert mock_tasks_api.return_value.create_task.called

@pytest.mark.db_test
@patch("airflow.providers.asana.hooks.asana.TasksApi", autospec=True, return_value=asana_tasks_api_mock)
def test_asana_find_task_operator(self, mock_tasks_api):
"""
Expand All @@ -84,6 +84,7 @@ def test_asana_find_task_operator(self, mock_tasks_api):
find_task.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)
assert mock_tasks_api.return_value.get_tasks.called

@pytest.mark.db_test
@patch("airflow.providers.asana.hooks.asana.TasksApi", autospec=True, return_value=asana_tasks_api_mock)
def test_asana_update_task_operator(self, mock_tasks_api):
"""
Expand All @@ -99,6 +100,7 @@ def test_asana_update_task_operator(self, mock_tasks_api):
update_task.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)
assert mock_tasks_api.return_value.update_task.called

@pytest.mark.db_test
@patch("airflow.providers.asana.hooks.asana.TasksApi", autospec=True, return_value=asana_tasks_api_mock)
def test_asana_delete_task_operator(self, mock_tasks_api):
"""
Expand Down