diff --git a/.github/trigger_files/beam_PostCommit_Python_MongoDBIO_IT.json b/.github/trigger_files/beam_PostCommit_Python_MongoDBIO_IT.json new file mode 100644 index 000000000000..0967ef424bce --- /dev/null +++ b/.github/trigger_files/beam_PostCommit_Python_MongoDBIO_IT.json @@ -0,0 +1 @@ +{} diff --git a/sdks/python/apache_beam/io/mongodbio.py b/sdks/python/apache_beam/io/mongodbio.py index 62cfc21df746..aede27674f8f 100644 --- a/sdks/python/apache_beam/io/mongodbio.py +++ b/sdks/python/apache_beam/io/mongodbio.py @@ -264,10 +264,6 @@ def __init__( self.projection = projection self.spec = extra_client_params self.bucket_auto = bucket_auto - self.client = MongoClient( - self.uri, - **self.spec, - driver=DriverInfo("Apache Beam", beam.__version__)) if "driver" not in self.spec: self.spec["driver"] = DriverInfo(