Skip to content

Commit 9983d7a

Browse files
committed
pin read to python provider
1 parent 5808923 commit 9983d7a

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

sdks/python/apache_beam/yaml/tests/mongodb.yaml

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,4 +70,11 @@ pipelines:
7070
input: ReadData.my_error_output
7171
config:
7272
elements: []
73-
73+
# TODO: Remove when Java ReadFromMongoDB (MongoDbIO) is migrated from
74+
# legacy BoundedSource to a DoFn/SDF-based reader.
75+
providers:
76+
- type: python
77+
config: { }
78+
transforms:
79+
ReadFromMongoDB: 'apache_beam.yaml.yaml_io.read_from_mongodb'
80+

0 commit comments

Comments
 (0)