Repository: incubator-airflow Updated Branches: refs/heads/master 8aa7160c4 -> 01952b37b
[AIRFLOW-239] Fix tests indentation Closes #1591 from zodiac/deindent-tests Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/01952b37 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/01952b37 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/01952b37 Branch: refs/heads/master Commit: 01952b37b574cbe08a5f2e3987d3360325c63a3e Parents: 8aa7160 Author: Li Xuanji <xua...@gmail.com> Authored: Wed Jun 15 11:21:56 2016 -0700 Committer: Dan Davydov <dan.davy...@airbnb.com> Committed: Wed Jun 15 11:21:56 2016 -0700 ---------------------------------------------------------------------- tests/core.py | 50 ++++++++++++++++++++++++-------------------------- 1 file changed, 24 insertions(+), 26 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/01952b37/tests/core.py ---------------------------------------------------------------------- diff --git a/tests/core.py b/tests/core.py index bbf9e60..af791e3 100644 --- a/tests/core.py +++ b/tests/core.py @@ -1587,33 +1587,31 @@ if 'AIRFLOW_RUNALL_TESTS' in os.environ: task_id='presto_check', sql=sql, dag=self.dag) t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, force=True) + def test_presto_to_mysql(self): + t = operators.PrestoToMySqlTransfer( + task_id='presto_to_mysql_check', + sql=""" + SELECT name, count(*) as ccount + FROM airflow.static_babynames + GROUP BY name + """, + mysql_table='test_static_babynames', + mysql_preoperator='TRUNCATE TABLE test_static_babynames;', + dag=self.dag) + t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, force=True) - def test_presto_to_mysql(self): - t = operators.PrestoToMySqlTransfer( - task_id='presto_to_mysql_check', - sql=""" - SELECT name, count(*) as ccount - FROM airflow.static_babynames - GROUP BY name - """, - mysql_table='test_static_babynames', - mysql_preoperator='TRUNCATE TABLE test_static_babynames;', - dag=self.dag) - t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, force=True) - - - def test_presto_to_mysql(self): - t = operators.PrestoToMySqlTransfer( - task_id='presto_to_mysql_check', - sql=""" - SELECT name, count(*) as ccount - FROM airflow.static_babynames - GROUP BY name - """, - mysql_table='test_static_babynames', - mysql_preoperator='TRUNCATE TABLE test_static_babynames;', - dag=self.dag) - t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, force=True) + def test_presto_to_mysql(self): + t = operators.PrestoToMySqlTransfer( + task_id='presto_to_mysql_check', + sql=""" + SELECT name, count(*) as ccount + FROM airflow.static_babynames + GROUP BY name + """, + mysql_table='test_static_babynames', + mysql_preoperator='TRUNCATE TABLE test_static_babynames;', + dag=self.dag) + t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, force=True) def test_hdfs_sensor(self): t = operators.HdfsSensor(