From 16f1ec92e16ebb19795490c6aadb8a98cf299130 Mon Sep 17 00:00:00 2001 From: Pablo Rodriguez Defino Date: Mon, 21 Oct 2024 16:37:20 -0700 Subject: [PATCH] fix type signature --- sdks/python/apache_beam/io/gcp/bigquery.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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):