beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pabl...@apache.org
Subject [beam] branch master updated: [BEAM-8311] Fix py mongodbio display data
Date Wed, 25 Sep 2019 00:36:38 GMT
This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 656cc76  [BEAM-8311] Fix py mongodbio display data
     new 4ea54ca  Merge pull request #9656 from y1chi/BEAM-8311
656cc76 is described below

commit 656cc76a217457c2b66d4f37d2681359d1fb662e
Author: Yichi Zhang <zyichi@google.com>
AuthorDate: Tue Sep 24 14:17:06 2019 -0700

    [BEAM-8311] Fix py mongodbio display data
---
 sdks/python/apache_beam/io/mongodbio.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/io/mongodbio.py b/sdks/python/apache_beam/io/mongodbio.py
index 39fec8d..6004ca1 100644
--- a/sdks/python/apache_beam/io/mongodbio.py
+++ b/sdks/python/apache_beam/io/mongodbio.py
@@ -203,8 +203,8 @@ class _BoundedMongoSource(iobase.BoundedSource):
     res['uri'] = self.uri
     res['database'] = self.db
     res['collection'] = self.coll
-    res['filter'] = self.filter
-    res['project'] = self.projection
+    res['filter'] = json.dumps(self.filter)
+    res['projection'] = str(self.projection)
     res['mongo_client_spec'] = json.dumps(self.spec)
     return res
 


Mime
View raw message