You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by jh...@apache.org on 2021/08/17 21:47:56 UTC
[airflow] 05/06: Remove repeated test.
This is an automated email from the ASF dual-hosted git repository.
jhtimmins pushed a commit to branch v2-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 489f9be29892cd82abfc34742ec5f921817ee51a
Author: James Timmins <ja...@astronomer.io>
AuthorDate: Mon Aug 16 19:04:13 2021 -0700
Remove repeated test.
---
tests/jobs/test_local_task_job.py | 28 ----------------------------
1 file changed, 28 deletions(-)
diff --git a/tests/jobs/test_local_task_job.py b/tests/jobs/test_local_task_job.py
index c18e6e5..14c74ce 100644
--- a/tests/jobs/test_local_task_job.py
+++ b/tests/jobs/test_local_task_job.py
@@ -864,34 +864,6 @@ class TestLocalTaskJob:
session.refresh(dr)
assert dr.state == State.SUCCESS
- def test_task_exit_should_update_state_of_finished_dagruns_with_dag_paused(self, dag_maker):
- """Test that with DAG paused, DagRun state will update when the tasks finishes the run"""
- with dag_maker(dag_id='test_dags') as dag:
- op1 = PythonOperator(task_id='dummy', python_callable=lambda: True)
-
- session = settings.Session()
- dagmodel = dag_maker.dag_model
- dagmodel.next_dagrun_create_after = dag.following_schedule(DEFAULT_DATE)
- dagmodel.is_paused = True
- session.merge(dagmodel)
- session.flush()
-
- # Write Dag to DB
- dagbag = DagBag(dag_folder="/dev/null", include_examples=False, read_dags_from_db=False)
- dagbag.bag_dag(dag, root_dag=dag)
- dagbag.sync_to_db()
-
- dr = dag_maker.create_dagrun(run_type=DagRunType.SCHEDULED)
-
- assert dr.state == State.RUNNING
- ti = TaskInstance(op1, dr.execution_date)
- job1 = LocalTaskJob(task_instance=ti, ignore_ti_state=True, executor=SequentialExecutor())
- job1.task_runner = StandardTaskRunner(job1)
- job1.run()
- session.add(dr)
- session.refresh(dr)
- assert dr.state == State.SUCCESS
-
@pytest.fixture()
def clean_db_helper():