Function EnvWaitForEqualTablesWithNames

flow/e2e/test_utils.go:163–191

(
	env WorkflowRun,
	suite RowSource,
	reason string,
	srcTable string,
	dstTable string,
	cols string,
)

}

func EnvWaitForEqualTablesWithNames(
	env WorkflowRun,
	suite RowSource,
	reason string,
	srcTable string,
	dstTable string,
	cols string,
) {
	t := suite.T()
	t.Helper()

	EnvWaitFor(t, env, 3*time.Minute, reason, func() bool {
		t.Helper()

		sourceRows, err := suite.Source().GetRows(t.Context(), suite.Suffix(), srcTable, cols)
		if err != nil {
			t.Log(err)
			return false
		}

		rows, err := suite.GetRows(dstTable, cols)
		if err != nil {
			t.Log(err)
			return false
		}

		return e2eshared.CheckEqualRecordBatches(t, sourceRows, rows)
	})
}

func EnvWaitForEqualTablesWithNames_Only(
	env WorkflowRun,