airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-239] Fix tests indentation
Date Wed, 15 Jun 2016 18:22:17 GMT
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 <xuanji@gmail.com>
Authored: Wed Jun 15 11:21:56 2016 -0700
Committer: Dan Davydov <dan.davydov@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(


Mime
View raw message