You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2022/02/09 14:24:35 UTC

[GitHub] [airflow] uranusjr commented on a change in pull request #21414: Some refactoring work on scheduling code

uranusjr commented on a change in pull request #21414:
URL: https://github.com/apache/airflow/pull/21414#discussion_r802715126



##########
File path: tests/models/test_dagrun.py
##########
@@ -17,161 +17,160 @@
 # under the License.
 
 import datetime
-import unittest
+from typing import Mapping, Optional
 from unittest import mock
 from unittest.mock import call
 
+import pendulum
 import pytest
-from parameterized import parameterized
+from sqlalchemy.orm.session import Session
 
-from airflow import models, settings
-from airflow.models import DAG, DagBag, DagModel, TaskInstance as TI, clear_task_instances
-from airflow.models.dagrun import DagRun
+from airflow import settings
+from airflow.models import DAG, DagBag, DagModel, DagRun, TaskInstance as TI, clear_task_instances
 from airflow.operators.dummy import DummyOperator
 from airflow.operators.python import ShortCircuitOperator
 from airflow.serialization.serialized_objects import SerializedDAG
 from airflow.stats import Stats
 from airflow.utils import timezone
 from airflow.utils.callback_requests import DagCallbackRequest
 from airflow.utils.dates import days_ago
-from airflow.utils.state import State
+from airflow.utils.state import DagRunState, State, TaskInstanceState
 from airflow.utils.trigger_rule import TriggerRule
 from airflow.utils.types import DagRunType
-from tests.models import DEFAULT_DATE
+from tests.models import DEFAULT_DATE as _DEFAULT_DATE
 from tests.test_utils.db import clear_db_dags, clear_db_pools, clear_db_runs
 from tests.test_utils.mock_operators import MockOperator
 
+DEFAULT_DATE = pendulum.instance(_DEFAULT_DATE)
 
-class TestDagRun(unittest.TestCase):
-    @classmethod
-    def setUpClass(cls):
-        cls.dagbag = DagBag(include_examples=True)
 
-    def setUp(self):
+class TestDagRun:
+    dagbag = DagBag(include_examples=True)

Review comment:
       I wondered about that but there’s no functional difference.




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org