airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xua...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-483] Change print to logging statement
Date Fri, 02 Sep 2016 16:00:56 GMT
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 <alexf@markovian.com>
Authored: Fri Sep 2 23:59:30 2016 +0800
Committer: Li Xuanji <xuanji@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)


Mime
View raw message