fix workflow integration test

nucleuscloud · Oct 24, 2024 · 0beadd9 · 0beadd9
1 parent f6e1087
commit 0beadd9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/worker/pkg/workflows/datasync/workflow/workflow_integration_test.go b/worker/pkg/workflows/datasync/workflow/workflow_integration_test.go
@@ -453,7 +453,9 @@ func toRunContextKeyString(id *mgmtv1alpha1.RunContextKey) string {
 func (s *IntegrationTestSuite) Test_Workflow_VirtualForeignKeys_Transform() {
 	testFolder := "testdata/postgres/virtual-foreign-keys"
 	// setup
-	err := s.postgres.Target.RunSqlFiles(s.ctx, &testFolder, []string{"target-setup.sql"})
+	err := s.postgres.Source.RunSqlFiles(s.ctx, &testFolder, []string{"source-setup.sql"})
+	require.NoError(s.T(), err)
+	err = s.postgres.Target.RunSqlFiles(s.ctx, &testFolder, []string{"target-setup.sql"})
 	require.NoError(s.T(), err)
 
 	virtualForeignKeys := testdata_virtualforeignkeys.GetVirtualForeignKeys()