You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by xu...@apache.org on 2016/09/02 16:00:56 UTC
incubator-airflow git commit: [AIRFLOW-483] Change print to logging
statement
Repository: incubator-airflow
Updated Branches:
refs/heads/master 0bdcdbe55 -> 2de790a98
[AIRFLOW-483] Change print to logging statement
Dear Airflow Maintainers,
Please accept this PR that addresses the following
issues:
https://issues.apache.org/jira/browse/AIRFLOW-483
Testing Done:
This fix prevented the stdout from being spammed
by the file content.
Closes #1780 from
skogsbaeck/fix/gcs_download_operator
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/2de790a9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/2de790a9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/2de790a9
Branch: refs/heads/master
Commit: 2de790a988838064ae1eb297b619506f8bda6e02
Parents: 0bdcdbe
Author: alexf <al...@markovian.com>
Authored: Fri Sep 2 23:59:30 2016 +0800
Committer: Li Xuanji <xu...@gmail.com>
Committed: Fri Sep 2 23:59:30 2016 +0800
----------------------------------------------------------------------
airflow/contrib/operators/gcs_download_operator.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/2de790a9/airflow/contrib/operators/gcs_download_operator.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/operators/gcs_download_operator.py b/airflow/contrib/operators/gcs_download_operator.py
index 1d78cad..d1ad3c3 100644
--- a/airflow/contrib/operators/gcs_download_operator.py
+++ b/airflow/contrib/operators/gcs_download_operator.py
@@ -81,4 +81,4 @@ class GoogleCloudStorageDownloadOperator(BaseOperator):
context['ti'].xcom_push(key=self.store_to_xcom_key, value=file_bytes)
else:
raise RuntimeError('The size of the downloaded file is too large to push to XCom!')
- print(file_bytes)
+ logging.info(file_bytes)