def *process_record*(self, record: dict, context: dict) -> None:

<http://logger.info|logger.info>(f"Processing record: {record}")

logger.debug(f"Context in process_record: {context}")

logger.debug(f"Stream name from self: {self.stream_name}")

try:

if self.stream_schema is None:

self.stream_schema = self.schema

self.buffer.append(record)

logger.debug(f"Buffer size: {len(self.buffer)}")

if (len(self.buffer) >= self.max_buffer_size) or self.force_flush:

self.flush_buffer(context)

self.force_flush = False

except Exception as e:

logger.error(f"Error processing record: {e}")

raise