Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/import-scene-test-dev.yml
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ jobs:
run: |
if [ -z ${{ github.event.inputs.testCase }} ]; then
echo "Running all tests"
go run gotest.tools/gotestsum@latest --format standard-verbose -- sceneTest/import/* -timeout 30m -args --cid 10987985172501194742 --config "${{ secrets.TEST_CONFIG_DEV }}" --test.timeout 30m
go run gotest.tools/gotestsum@latest --format standard-verbose -- sceneTest/import/* -timeout 30m -args --cid 10987985172501194742 --config "${{ secrets.TEST_CONFIG_DEV }}" --test.timeout 30m --test.skip "TestS3Arn"
else
echo "Running test ${{ github.event.inputs.testCase }}"
go run gotest.tools/gotestsum@latest --format standard-verbose -- sceneTest/import/* -args --cid 10987985172501194742 --config "${{ secrets.TEST_CONFIG_DEV }}" --test.run ${{ github.event.inputs.testCase }}
Expand Down
72 changes: 36 additions & 36 deletions sceneTest/import/import_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -180,39 +180,39 @@ func TestSchemaColumnNumberMismatchedImport(t *testing.T) {
}

// TestZeroDateImport verifies zero date strings can be imported without errors
// func TestZeroDateImport(t *testing.T) {
// ctx := context.Background()

// if _, err := db.ExecContext(ctx, "DROP TABLE IF EXISTS `test`.`zero_date`"); err != nil {
// t.Fatalf("Failed to drop zero date import table: %v", err)
// }

// cfg := config.LoadConfig()

// importOptions := imp.ImportOptions{
// FileType: imp.IMPORTFILETYPEENUM_CSV,
// CsvFormat: &imp.CSVFormat{
// Separator: pointer.ToString(";"),
// },
// }

// s3Source := &imp.S3Source{
// Uri: cfg.Import.S3.ZeroDateURI,
// AuthType: imp.IMPORTS3AUTHTYPEENUM_ACCESS_KEY,
// AccessKey: &imp.S3SourceAccessKey{
// Id: cfg.S3.AccessKeyID,
// Secret: cfg.S3.SecretAccessKey,
// },
// }

// importID, err := createS3Import(ctx, importOptions, s3Source)
// if err != nil {
// t.Fatalf("Failed to create zero date import: %v", err)
// }

// if err := waitImport(ctx, importID); err != nil {
// t.Fatalf("Zero date import failed, importId: %s, error: %v", importID, err)
// }

// t.Log("Zero date import completed successfully")
// }
func TestZeroDateImport(t *testing.T) {
ctx := context.Background()

if _, err := db.ExecContext(ctx, "DROP TABLE IF EXISTS `test`.`zero_date`"); err != nil {
t.Fatalf("Failed to drop zero date import table: %v", err)
}

cfg := config.LoadConfig()

importOptions := imp.ImportOptions{
FileType: imp.IMPORTFILETYPEENUM_CSV,
CsvFormat: &imp.CSVFormat{
Separator: pointer.ToString(";"),
},
}

s3Source := &imp.S3Source{
Uri: cfg.Import.S3.ZeroDateURI,
AuthType: imp.IMPORTS3AUTHTYPEENUM_ACCESS_KEY,
AccessKey: &imp.S3SourceAccessKey{
Id: cfg.S3.AccessKeyID,
Secret: cfg.S3.SecretAccessKey,
},
}

importID, err := createS3Import(ctx, importOptions, s3Source)
if err != nil {
t.Fatalf("Failed to create zero date import: %v", err)
}

if err := waitImport(ctx, importID); err != nil {
t.Fatalf("Zero date import failed, importId: %s, error: %v", importID, err)
}

t.Log("Zero date import completed successfully")
}
Loading