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-402] Remove NamedHivePartitionSensor static check, add docs
Date Tue, 09 Aug 2016 22:39:36 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 55985ef2d -> f1abffa38


[AIRFLOW-402] Remove NamedHivePartitionSensor static check, add docs

Addresses the following issues:
[https://issues.apache.org/jira/browse/AIRFLOW-402](https://issues.apache.org/jira/browse/AIRFLOW-402)

Closes #1711 from zodiac/fix_named_hive_partition_sensor


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/f1abffa3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/f1abffa3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/f1abffa3

Branch: refs/heads/master
Commit: f1abffa3805930dbe9ed7304e70431da1025f0db
Parents: 55985ef
Author: Li Xuanji <xuanji@gmail.com>
Authored: Tue Aug 9 15:38:57 2016 -0700
Committer: Dan Davydov <dan.davydov@airbnb.com>
Committed: Tue Aug 9 15:39:02 2016 -0700

----------------------------------------------------------------------
 airflow/operators/sensors.py | 3 ---
 docs/code.rst                | 1 +
 2 files changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/f1abffa3/airflow/operators/sensors.py
----------------------------------------------------------------------
diff --git a/airflow/operators/sensors.py b/airflow/operators/sensors.py
index fbc8569..e40292a 100644
--- a/airflow/operators/sensors.py
+++ b/airflow/operators/sensors.py
@@ -271,9 +271,6 @@ class NamedHivePartitionSensor(BaseSensorOperator):
         if isinstance(partition_names, basestring):
             raise TypeError('partition_names must be an array of strings')
 
-        for partition_name in partition_names:
-            self.parse_partition_name(partition_name)
-
         self.metastore_conn_id = metastore_conn_id
         self.partition_names = partition_names
         self.next_poke_idx = 0

http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/f1abffa3/docs/code.rst
----------------------------------------------------------------------
diff --git a/docs/code.rst b/docs/code.rst
index ba1cddb..8548120 100644
--- a/docs/code.rst
+++ b/docs/code.rst
@@ -66,6 +66,7 @@ Operator API
         MsSqlToHiveTransfer,
         MySqlOperator,
         MySqlToHiveTransfer,
+        NamedHivePartitionSensor,
         PostgresOperator,
         PrestoCheckOperator,
         PrestoIntervalCheckOperator,


Mime
View raw message