Function await_progress

src/environmentd/tests/sql.rs:753–769

Asserts that the next message has a timestamp of at least `ts` and is a progress message. Returns the timestamp of the progress message.

(
                    client: &mut postgres::Client,
                    last_seen_ts: &mut u64,
                    ts: u64,
                )

                //
                // Returns the timestamp of the progress message.
                fn await_progress(
                    client: &mut postgres::Client,
                    last_seen_ts: &mut u64,
                    ts: u64,
                ) -> u64 {
                    debug!("awaiting progress");
                    let row = client.query_one("FETCH 1 c1", &[]).unwrap();
                    debug!(?row);
                    assert_eq!(row.get::<_, bool>("mz_progressed"), true);
                    assert_eq!(row.get::<_, Option<i64>>("mz_diff"), None);
                    assert_eq!(row.get::<_, Option<String>>("data"), None);
                    let progress_ts = row.get::<_, MzTimestamp>("mz_timestamp").0;
                    assert!(progress_ts >= ts);
                    assert!(progress_ts >= *last_seen_ts);
                    *last_seen_ts = progress_ts;
                    progress_ts
                }

                let mut last_seen_ts = 0;