@@ -40,41 +40,36 @@ pipelines:
4040 input : WriteData.my_error_output
4141 config :
4242 elements : []
43- - pipeline :
44- type : composite
45- transforms :
46- - type : ReadFromMongoDB
47- name : ReadData
48- config :
49- connection_uri : ' {mongo_vars[URI]}'
50- database : ' {mongo_vars[DATABASE]}'
51- collection : ' {mongo_vars[COLLECTION]}'
52- schema : |
53- {
54- "type": "object",
55- "properties": {
56- "name": {"type": "string"},
57- "age": {"type": "integer"}
58- },
59- "required": ["name", "age"]
60- }
61- error_handling :
62- output : my_error_output
63- - type : AssertEqual
64- input : ReadData
65- config :
66- elements :
67- - { name: "John", age: 30 }
68- - { name: "Jane", age: 25 }
69- - type : AssertEqual
70- input : ReadData.my_error_output
71- config :
72- elements : []
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'
43+ # TODO: Re-enable ReadFromMongoDB tests once Java MongoDbIO is migrated from legacy BoundedSource.
44+ # - pipeline:
45+ # type: composite
46+ # transforms:
47+ # - type: ReadFromMongoDB
48+ # name: ReadData
49+ # config:
50+ # connection_uri: '{mongo_vars[URI]}'
51+ # database: '{mongo_vars[DATABASE]}'
52+ # collection: '{mongo_vars[COLLECTION]}'
53+ # schema: |
54+ # {
55+ # "type": "object",
56+ # "properties": {
57+ # "name": {"type": "string"},
58+ # "age": {"type": "integer"}
59+ # },
60+ # "required": ["name", "age"]
61+ # }
62+ # error_handling:
63+ # output: my_error_output
64+ # - type: AssertEqual
65+ # input: ReadData
66+ # config:
67+ # elements:
68+ # - { name: "John", age: 30 }
69+ # - { name: "Jane", age: 25 }
70+ # - type: AssertEqual
71+ # input: ReadData.my_error_output
72+ # config:
73+ # elements: []
74+
8075
0 commit comments