Skip to content

Commit b781649

Browse files
committed
Build query from input values when batching with fields
1 parent 8fddd96 commit b781649

File tree

1 file changed

+1
-1
lines changed
  • sdks/python/apache_beam/transforms/enrichment_handlers

1 file changed

+1
-1
lines changed

sdks/python/apache_beam/transforms/enrichment_handlers/bigquery.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -188,7 +188,7 @@ def __call__(self, request: Union[beam.Row, list[beam.Row]], *args, **kwargs):
188188
responses = []
189189
requests_map: dict[Any, Any] = {}
190190
batch_size = len(request)
191-
if batch_size > 1 and self.fields and len(self.fields) > 0:
191+
if self.fields and len(self.fields) > 0:
192192
unique_values = set()
193193
field_name = self.fields[0]
194194
for req in request:

0 commit comments

Comments
 (0)