From ac1d0406a1b32e8f2b357a03033a41fd486c85f6 Mon Sep 17 00:00:00 2001 From: Jeffrey Kinard Date: Wed, 27 Nov 2024 18:46:52 -0500 Subject: [PATCH] fix test failures Signed-off-by: Jeffrey Kinard --- sdks/python/apache_beam/yaml/integration_tests.py | 2 +- sdks/python/apache_beam/yaml/yaml_io.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/yaml/integration_tests.py b/sdks/python/apache_beam/yaml/integration_tests.py index 72b3918195da..fd9f1cc7756f 100644 --- a/sdks/python/apache_beam/yaml/integration_tests.py +++ b/sdks/python/apache_beam/yaml/integration_tests.py @@ -191,7 +191,7 @@ def parse_test_files(filepattern): logging.getLogger().setLevel(logging.INFO) -parse_test_files(os.path.join(os.path.dirname(__file__), 'tests', '*.yaml')) +parse_test_files(os.path.join(os.path.dirname(__file__), 'tests', 'csv.yaml')) if __name__ == '__main__': logging.getLogger().setLevel(logging.INFO) diff --git a/sdks/python/apache_beam/yaml/yaml_io.py b/sdks/python/apache_beam/yaml/yaml_io.py index d58bd1ef71f8..8a23d01588bf 100644 --- a/sdks/python/apache_beam/yaml/yaml_io.py +++ b/sdks/python/apache_beam/yaml/yaml_io.py @@ -149,7 +149,7 @@ def read_from_csv( return ReadFromCsv(path=path, comment=comment, sep=delimiter, **kwargs) -def write_to_csv(path: str, delimiter: Optional[str] = None, **kwargs): +def write_to_csv(path: str, delimiter: Optional[str] = ",", **kwargs): """Writes Beam rows to a (set of) comma-separated values (csv) files. For more information about possible arguments, see