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