Skip to content

Commit

Permalink
add mid date
Browse files Browse the repository at this point in the history
  • Loading branch information
Amogh-Bharadwaj committed Feb 28, 2024
1 parent 57976f0 commit 591f6f3
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion flow/e2e/bigquery/qrep_flow_bq_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ func (s PeerFlowE2ETestSuiteBQ) setupTimeTable(tableName string) {
"watermark_ts timestamp",
"mytimestamp timestamp",
"mytztimestamp timestamptz",
"medieval timestamptz",
"mybaddate date",
"mydate date",
}
Expand All @@ -37,6 +38,7 @@ func (s PeerFlowE2ETestSuiteBQ) setupTimeTable(tableName string) {
row := `(CURRENT_TIMESTAMP,
'10001-03-14 23:05:52',
'50001-03-14 23:05:52.216809+00'
'1534-03-14 23:05:52.216809+00',
'10000-03-14',
CURRENT_TIMESTAMP)`
rows = append(rows, row)
Expand All @@ -46,6 +48,7 @@ func (s PeerFlowE2ETestSuiteBQ) setupTimeTable(tableName string) {
watermark_ts,
mytimestamp,
mytztimestamp,
medieval,
mybaddate,
mydate
) VALUES %s;
Expand Down Expand Up @@ -112,7 +115,7 @@ func (s PeerFlowE2ETestSuiteBQ) Test_Invalid_Timestamps_And_Date_QRep() {
require.NoError(s.t, err)

goodValues := []string{"watermark_ts", "mydate"}
badValues := []string{"mytimestamp", "mytztimestamp", "mybaddate"}
badValues := []string{"mytimestamp", "mytztimestamp", "medieval", "mybaddate"}

for _, col := range goodValues {
ok, err := s.bqHelper.CheckNull(tblName, []string{col})
Expand Down

0 comments on commit 591f6f3

Please sign in to comment.