change TARGET_PARTITION_SIZE to DEFAULT_TARGET_PARTITION_SIZE
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/8bedf334 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/8bedf334 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/8bedf334 Branch: refs/heads/airbnb_rb1.7.1_4 Commit: 8bedf334801fc7db396d7c75c4c385808398bba3 Parents: b58b5e0 Author: Hongbo Zeng <hongbo.z...@airbnb.com> Authored: Mon May 16 11:20:49 2016 -0700 Committer: Dan Davydov <dan.davy...@airbnb.com> Committed: Mon May 23 16:59:57 2016 -0700 ---------------------------------------------------------------------- airflow/hooks/druid_hook.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/8bedf334/airflow/hooks/druid_hook.py ---------------------------------------------------------------------- diff --git a/airflow/hooks/druid_hook.py b/airflow/hooks/druid_hook.py index 7c80c7c..bb6d9fa 100644 --- a/airflow/hooks/druid_hook.py +++ b/airflow/hooks/druid_hook.py @@ -10,7 +10,7 @@ from airflow.hooks.base_hook import BaseHook from airflow.exceptions import AirflowException LOAD_CHECK_INTERVAL = 5 -TARGET_PARTITION_SIZE = 5000000 +DEFAULT_TARGET_PARTITION_SIZE = 5000000 class AirflowDruidLoadException(AirflowException): pass @@ -64,7 +64,7 @@ class DruidHook(BaseHook): # and overwrites the num_shards if target_partition_size == -1: if num_shards == -1: - target_partition_size = TARGET_PARTITION_SIZE + target_partition_size = DEFAULT_TARGET_PARTITION_SIZE else: num_shards = -1