@@ -53,12 +53,21 @@ func cleanupSharedResources() {
53
53
deletePrivateLinkEndpoint (projectID , sharedInfo .privateLinkProviderName , sharedInfo .privateLinkEndpointID )
54
54
}
55
55
if sharedInfo .encryptionAtRestEnabled {
56
- projectID := sharedInfo .projectID
56
+ projectID := sharedInfo .encryptionAtRestProjectID
57
57
if projectID == "" {
58
- projectID = projectIDLocal ()
58
+ projectID = sharedInfo .projectID
59
+ if projectID == "" {
60
+ projectID = projectIDLocal ()
61
+ }
59
62
}
60
63
fmt .Printf ("Deleting execution encryption at rest: project id: %s\n " , projectID )
61
64
deleteEncryptionAtRest (projectID )
65
+
66
+ // If we created a dedicated project, delete it
67
+ if sharedInfo .encryptionAtRestProjectID != "" && sharedInfo .encryptionAtRestProjectID != sharedInfo .projectID {
68
+ fmt .Printf ("Deleting execution encryption at rest project: %s, id: %s\n " , sharedInfo .encryptionAtRestProjectName , sharedInfo .encryptionAtRestProjectID )
69
+ deleteProject (sharedInfo .encryptionAtRestProjectID )
70
+ }
62
71
}
63
72
if sharedInfo .projectID != "" {
64
73
fmt .Printf ("Deleting execution project: %s, id: %s\n " , sharedInfo .projectName , sharedInfo .projectID )
@@ -216,17 +225,19 @@ type projectInfo struct {
216
225
}
217
226
218
227
var sharedInfo = struct {
219
- projectID string
220
- projectName string
221
- clusterName string
222
- streamInstanceName string
223
- privateLinkEndpointID string
224
- privateLinkProviderName string
225
- projects []projectInfo
226
- mu sync.Mutex
227
- muSleep sync.Mutex
228
- encryptionAtRestEnabled bool
229
- init bool
228
+ encryptionAtRestProjectName string
229
+ projectName string
230
+ clusterName string
231
+ streamInstanceName string
232
+ privateLinkEndpointID string
233
+ privateLinkProviderName string
234
+ projectID string
235
+ encryptionAtRestProjectID string
236
+ projects []projectInfo
237
+ mu sync.Mutex
238
+ muSleep sync.Mutex
239
+ encryptionAtRestEnabled bool
240
+ init bool
230
241
}{
231
242
projects : []projectInfo {},
232
243
}
0 commit comments