Airtable fix

This commit is contained in:
Weves 2025-01-31 10:32:04 -08:00 committed by Chris Weaver
parent 261150e81a
commit 7bc8554e01

View File

@ -368,10 +368,8 @@ class AirtableConnector(LoadConnector):
logger.exception(f"Failed to process record {record['id']}")
raise e
# After batch is complete, yield if we've hit the batch size
if len(record_documents) >= self.batch_size:
yield record_documents
record_documents = []
yield record_documents
record_documents = []
# Yield any remaining records
if record_documents: