Update sdks/python/apache_beam/io/gcp/bigquery_tools.py

Co-authored-by: Ahmed Abualsaud <[email protected]>
apache · Feb 3, 2025 · d6007dc · d6007dc
1 parent 2d19e07
commit d6007dc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/io/gcp/bigquery_tools.py b/sdks/python/apache_beam/io/gcp/bigquery_tools.py
@@ -1608,7 +1608,7 @@ def beam_row_from_dict(row: dict, schema):
     # For this case, we create the field with a `None` value
     # None is also set when a repeated field is missing as BigQuery
     # converts Null Repeated fields to empty lists
-    if name not in row and (mode == "NULLABLE" or mode == "REPEATED"):
+    if name not in row and mode != "REQUIRED":
       row[name] = None
 
     value = row[name]