source-postgres: read() throws config exception upon xmin wraparound

[theyueli]

fixes https://github.com/airbytehq/airbyte-internal-issues/issues/8006

[vercel]

The latest updates on your projects. Learn more about Vercel for Git ↗︎

1 Ignored Deployment

Name	Status	Preview	Comments	Updated (UTC)
airbyte-docs	⬜️ Ignored (Inspect)	Visit Preview		Jun 5, 2024 7:33am

[akashkulk]

Thanks for taking this!

We actually get the xmin status in the read path here : https://github.com/airbytehq/airbyte/blob/master/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSource.java#L503

We can just piggyback there, check if xmin wraparound is > 0 and throw a config error there. It's not clear to me we will require a standalone method there at this point

[theyueli]

Thanks for taking this!

We actually get the xmin status in the read path here : https://github.com/airbytehq/airbyte/blob/master/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSource.java#L503

We can just piggyback there, check if xmin wraparound is > 0 and throw a config error there. It's not clear to me we will require a standalone method there at this point

agreed, that's indeed very convenient. Thanks for pointing to this place. I actually didn't notice the function is already called there. Revised, please take another look.