diff --git a/.github/workflows/beam_PreCommit_GHA.yml b/.github/workflows/beam_PreCommit_GHA.yml index 7ad6b5e67583..13bcef3e41e2 100644 --- a/.github/workflows/beam_PreCommit_GHA.yml +++ b/.github/workflows/beam_PreCommit_GHA.yml @@ -93,3 +93,4 @@ jobs: uses: ./.github/actions/gradle-command-self-hosted-action with: gradle-command: :beam-test-gha:preCommit + diff --git a/sdks/python/apache_beam/yaml/yaml_io.py b/sdks/python/apache_beam/yaml/yaml_io.py index bf0b0a4c6ec2..6856f014193e 100644 --- a/sdks/python/apache_beam/yaml/yaml_io.py +++ b/sdks/python/apache_beam/yaml/yaml_io.py @@ -824,6 +824,7 @@ def write_to_mongodb( batch_size: Number of documents per bulk_write to MongoDB. """ def row_to_dict(value): + if value is None: return None if hasattr(value, '_asdict'):