You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/05/10 17:40:59 UTC
incubator-airflow git commit: [AIRFLOW-2449] Fix operators.py to run
all test cases
Repository: incubator-airflow
Updated Branches:
refs/heads/master 5de22d7fa -> 0ae21cf6e
[AIRFLOW-2449] Fix operators.py to run all test cases
MySqlTest and PostgresTest in
tests/operators/operators.py
have some unexecuted tests due to wrong naming
convention.
This PR fixes it.
Closes #3344 from sekikn/AIRFLOW-2449
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/0ae21cf6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/0ae21cf6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/0ae21cf6
Branch: refs/heads/master
Commit: 0ae21cf6e5991e5f8adccb413b513bc3bc7361b1
Parents: 5de22d7
Author: Kengo Seki <se...@apache.org>
Authored: Thu May 10 19:40:52 2018 +0200
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Thu May 10 19:40:52 2018 +0200
----------------------------------------------------------------------
tests/operators/operators.py | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/0ae21cf6/tests/operators/operators.py
----------------------------------------------------------------------
diff --git a/tests/operators/operators.py b/tests/operators/operators.py
index 97cee75..9fc2c93 100644
--- a/tests/operators/operators.py
+++ b/tests/operators/operators.py
@@ -45,7 +45,7 @@ class MySqlTest(unittest.TestCase):
dag = DAG(TEST_DAG_ID, default_args=args)
self.dag = dag
- def mysql_operator_test(self):
+ def test_mysql_operator_test(self):
sql = """
CREATE TABLE IF NOT EXISTS test_airflow (
dummy VARCHAR(50)
@@ -59,7 +59,7 @@ class MySqlTest(unittest.TestCase):
dag=self.dag)
t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)
- def mysql_operator_test_multi(self):
+ def test_mysql_operator_test_multi(self):
sql = [
"TRUNCATE TABLE test_airflow",
"INSERT INTO test_airflow VALUES ('X')",
@@ -71,7 +71,7 @@ class MySqlTest(unittest.TestCase):
sql=sql, dag=self.dag)
t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)
- def mysql_hook_test_bulk_load(self):
+ def test_mysql_hook_test_bulk_load(self):
records = ("foo", "bar", "baz")
import tempfile
@@ -140,7 +140,7 @@ class PostgresTest(unittest.TestCase):
dag = DAG(TEST_DAG_ID, default_args=args)
self.dag = dag
- def postgres_operator_test(self):
+ def test_postgres_operator_test(self):
sql = """
CREATE TABLE IF NOT EXISTS test_airflow (
dummy VARCHAR(50)
@@ -161,7 +161,7 @@ class PostgresTest(unittest.TestCase):
end_date=DEFAULT_DATE,
ignore_ti_state=True)
- def postgres_operator_test_multi(self):
+ def test_postgres_operator_test_multi(self):
sql = [
"TRUNCATE TABLE test_airflow",
"INSERT INTO test_airflow VALUES ('X')",