You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/07/23 00:18:01 UTC
[1/2] incubator-beam git commit: Log all exceptions in _start_upload
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 09b4daf23 -> 47042ce89
Log all exceptions in _start_upload
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5bfd4cb7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5bfd4cb7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5bfd4cb7
Branch: refs/heads/python-sdk
Commit: 5bfd4cb7e67dbe54cde728be0dc99a0343e64e69
Parents: 09b4daf
Author: Ahmet Altay <al...@google.com>
Authored: Fri Jul 22 10:24:24 2016 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Fri Jul 22 11:55:12 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/gcsio.py | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/5bfd4cb7/sdks/python/apache_beam/io/gcsio.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/gcsio.py b/sdks/python/apache_beam/io/gcsio.py
index 10409c9..9377266 100644
--- a/sdks/python/apache_beam/io/gcsio.py
+++ b/sdks/python/apache_beam/io/gcsio.py
@@ -579,11 +579,10 @@ class GcsBufferedWriter(object):
# a time, buffering writes until that size is reached.
try:
self.client.objects.Insert(self.insert_request, upload=self.upload)
- except HttpError as http_error:
+ except Exception as e: # pylint: disable=broad-except
logging.error(
- 'HTTP error while inserting file %s: %s', self.path, http_error)
- self.upload_thread.last_error = http_error
- raise
+ 'Error in _start_upload while inserting file %s: %s', self.path, e)
+ self.upload_thread.last_error = e
finally:
self.child_conn.close()
[2/2] incubator-beam git commit: Closes #713
Posted by dh...@apache.org.
Closes #713
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/47042ce8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/47042ce8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/47042ce8
Branch: refs/heads/python-sdk
Commit: 47042ce89cca22e48f00c3b9f8219eed85c119c6
Parents: 09b4daf 5bfd4cb
Author: Dan Halperin <dh...@google.com>
Authored: Fri Jul 22 17:17:53 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Fri Jul 22 17:17:53 2016 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/io/gcsio.py | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------