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/199e07a4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/199e07a4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/199e07a4 Branch: refs/heads/master Commit: 199e07a455e77ceb33e06ab7646fa957a5fbd232 Parents: b565ef9 Author: Hongbo Zeng <hongbo.z...@airbnb.com> Authored: Mon May 16 11:20:49 2016 -0700 Committer: Hongbo Zeng <hongbo.z...@airbnb.com> Committed: Mon May 16 11:20:49 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/199e07a4/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
