in app/com/gu/floodgate/AppComponents.scala [141:148]
def generateBulkActors(environment: String): ActorRef = {
val contentSources = contentSourceTable.getAllSync()
val idList = contentSources.filter(contentSource => contentSource.environment == environment).toList
pekkoActorSystem.actorOf(
BulkJobActor.props(idList, runningJobService, reindexService, jobHistoryService),
s"${environment}-bulk-job"
)
}