def METHOD_NAME(self, context: dict) -> None:
    """Write out any prepped records and return once fully written."""
    sf_object: bulk.SFBulkType = getattr(self.sf_client.bulk, self.stream_name)
    results = self._process_batch_by_action(
        sf_object, self.config.get("action"), self._batched_records
    )
    self._validate_batch_result(
        results, self.config.get("action"), self._batched_records
    )
    # Refresh session to avoid timeouts.
    self._new_session()