pub async fn create_postgres_source_with_table<'a>(
    mz_client: &Client,
    table_name: &str,
    table_schema: &str,
    source_name: &str
) -> (Client, impl FnOnce(&'a Client, &'a Client) -> LocalBoxFuture<'a, ()>)
Expand description

Helper function to create a Postgres source.

IMPORTANT: Make sure to call closure that is returned at the end of the test to clean up Postgres state.

WARNING: If multiple tests use this, and the tests are run in parallel, then make sure the test use different postgres tables.