diff --git a/sdks/python/apache_beam/io/gcp/bigquery.py b/sdks/python/apache_beam/io/gcp/bigquery.py
index ec9faa6f9029..f8250c561d6b 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery.py
@@ -1888,7 +1888,7 @@ def _restore_table_ref(sharded_table_ref_elems_kv):
 # CDC configuration type definition
 CdcWritesWithRows = Callable[[beam.pvalue.Row], beam.pvalue.Row]
 CdcWritesWithDicts = Callable[[Dict], Dict]
-UseCdcWrites = Union[bool, CdcWritesWithRows, CdcWritesWithRows]
+UseCdcWrites = Union[bool, CdcWritesWithRows, CdcWritesWithDicts]
 
 
 class WriteToBigQuery(PTransform):