File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed
sdks/python/apache_beam/io Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change 9797 from pymongo import DESCENDING
9898 from pymongo import MongoClient
9999 from pymongo import ReplaceOne
100- from pymongo .driver_info import DriverInfo
101100except ImportError :
102101 objectid = None
103102 json_util = None
106105 DESCENDING = - 1
107106 MongoClient = None
108107 ReplaceOne = None
109- DriverInfo = None
110108 _LOGGER .warning ("Could not find a compatible bson package." )
111109
112110__all__ = ["ReadFromMongoDB" , "WriteToMongoDB" ]
@@ -264,10 +262,6 @@ def __init__(
264262 self .projection = projection
265263 self .spec = extra_client_params
266264 self .bucket_auto = bucket_auto
267- self .client = MongoClient (
268- self .uri ,
269- ** self .spec ,
270- driver = DriverInfo ("Apache Beam" , beam .__version__ ))
271265
272266 if "driver" not in self .spec :
273267 self .spec ["driver" ] = DriverInfo (
You can’t perform that action at this time.
0 commit comments