airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From criccom...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1690] Add detail to gcs error messages
Date Fri, 06 Oct 2017 17:47:38 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/v1-9-test 0080f0fcc -> 5fb5cd10d


[AIRFLOW-1690] Add detail to gcs error messages

Provide the system error detail in the log
message.

Closes #2670 from wrp/master


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

Branch: refs/heads/v1-9-test
Commit: 5fb5cd10d3ae6760775b74f14e2f17d8b4ceac44
Parents: 0080f0f
Author: William Pursell <william@upthere.com>
Authored: Fri Oct 6 10:46:42 2017 -0700
Committer: Chris Riccomini <criccomini@apache.org>
Committed: Fri Oct 6 10:47:32 2017 -0700

----------------------------------------------------------------------
 airflow/utils/log/gcs_task_handler.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/5fb5cd10/airflow/utils/log/gcs_task_handler.py
----------------------------------------------------------------------
diff --git a/airflow/utils/log/gcs_task_handler.py b/airflow/utils/log/gcs_task_handler.py
index bb40e11..c11e7ad 100644
--- a/airflow/utils/log/gcs_task_handler.py
+++ b/airflow/utils/log/gcs_task_handler.py
@@ -167,8 +167,8 @@ class GCSTaskHandler(FileTaskHandler, LoggingMixin):
                 # closed).
                 tmpfile.flush()
                 self.hook.upload(bkt, blob, tmpfile.name)
-        except:
-            self.log.error('Could not write logs to %s', remote_log_location)
+        except Exception as e:
+            self.log.error('Could not write logs to %s: %s', remote_log_location, e)
 
     def parse_gcs_url(self, gsurl):
         """


Mime
View raw message