Skip to content

Commit 38192de

Browse files
authored
make validation for BQ export source configurable (#34651)
1 parent 58e1616 commit 38192de

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

Diff for: sdks/python/apache_beam/io/gcp/bigquery.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -784,14 +784,15 @@ def _get_project(self):
784784

785785
def _create_source(self, path, coder):
786786
if not self.use_json_exports:
787-
return create_avro_source(path)
787+
return create_avro_source(path, validate=self.validate)
788788
else:
789789
return TextSource(
790790
path,
791791
min_bundle_size=0,
792792
compression_type=CompressionTypes.UNCOMPRESSED,
793793
strip_trailing_newlines=True,
794-
coder=coder)
794+
coder=coder,
795+
validate=self.validate)
795796

796797
def split(self, desired_bundle_size, start_position=None, stop_position=None):
797798
if self.export_result is None:

0 commit comments

Comments
 (0)