Merge pull request #6700 from gchq/6675-grant-job-starter-permission-to-send-messages

patchwork01 · web-flow · commit 74b0b066a521 · 2026-02-25T15:43:36.000Z
6675: Grant persistent emr job starter function permission to send me…
diff --git a/java/deployment/cdk/src/main/java/sleeper/cdk/stack/bulkimport/PersistentEmrBulkImportStack.java b/java/deployment/cdk/src/main/java/sleeper/cdk/stack/bulkimport/PersistentEmrBulkImportStack.java
@@ -91,6 +91,7 @@ public PersistentEmrBulkImportStack(
                 bulkImportJobQueue, artefacts, importBucketStack.getImportBucket(),
                 LogGroupRef.BULK_IMPORT_EMR_PERSISTENT_START, commonEmrStack);
         configureJobStarterFunction(jobStarter);
+        bulkImportJobQueue.grantSendMessages(jobStarter);
         createCluster(this, instanceProperties, coreStacks, importBucketStack.getImportBucket(), commonEmrStack);
         Utils.addTags(this, instanceProperties);
     }

Original file line number	Diff line number	Diff line change
`@@ -91,6 +91,7 @@ public PersistentEmrBulkImportStack(`
`91`	`91`	`bulkImportJobQueue, artefacts, importBucketStack.getImportBucket(),`
`92`	`92`	`LogGroupRef.BULK_IMPORT_EMR_PERSISTENT_START, commonEmrStack);`
`93`	`93`	`configureJobStarterFunction(jobStarter);`
	`94`	`+ bulkImportJobQueue.grantSendMessages(jobStarter);`
`94`	`95`	`createCluster(this, instanceProperties, coreStacks, importBucketStack.getImportBucket(), commonEmrStack);`
`95`	`96`	`Utils.addTags(this, instanceProperties);`
`96`	`97`	`}`