Closed shankiyani closed 1 year ago
retrieving the latest checkpointID based on createdAt time is not sufficient given our burst like writes to BQ. This PR aims to track the new checkpoint and write it at the very end before returning.
retrieving the latest checkpointID based on createdAt time is not sufficient given our burst like writes to BQ. This PR aims to track the new checkpoint and write it at the very end before returning.