You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by da...@apache.org on 2016/06/15 18:22:17 UTC
incubator-airflow git commit: [AIRFLOW-239] Fix tests indentation
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 <xu...@gmail.com>
Authored: Wed Jun 15 11:21:56 2016 -0700
Committer: Dan Davydov <da...@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(