diff --git a/flow/e2e/s3/cdc_s3_test.go b/flow/e2e/s3/cdc_s3_test.go index b02c90d4fb..427e68282d 100644 --- a/flow/e2e/s3/cdc_s3_test.go +++ b/flow/e2e/s3/cdc_s3_test.go @@ -167,7 +167,7 @@ func (s *PeerFlowE2ETestSuiteS3) Test_Types_GCS_Interop() { srcTableName := s.attachSchemaSuffix("test_types_interop") dstTableName := fmt.Sprintf("%s.%s_%d", "peerdb_test_gcs_interop", "test_types_interop", time.Now().Unix()) - flowJobName := s.attachSuffix("test_simple_flow") + flowJobName := s.attachSuffix("test_types_interop_flow") createMoodEnum := "CREATE TYPE mood AS ENUM ('happy', 'sad', 'angry');" _, enumErr := s.pool.Exec(context.Background(), createMoodEnum)