only create datastore if needed for the broker

Signed-off-by: Brian Fletcher <brian@roadie.io>
This commit is contained in:
Brian Fletcher
2021-10-28 13:02:07 +01:00
parent 93d0ea4612
commit 66b5024b7c
@@ -89,12 +89,17 @@ export async function createRouter(
const workingDirectory = await getWorkingDirectory(config, logger);
const entityClient = new CatalogEntityClient(catalogClient);
const integrations = ScmIntegrations.fromConfig(config);
let taskBroker: TaskBroker;
if (!options.taskBroker) {
const databaseTaskStore = await DatabaseTaskStore.create({
database: await database.getClient(),
});
taskBroker = new StorageTaskBroker(databaseTaskStore, logger);
} else {
taskBroker = options.taskBroker;
}
const databaseTaskStore = await DatabaseTaskStore.create({
database: await database.getClient(),
});
const taskBroker =
options.taskBroker || new StorageTaskBroker(databaseTaskStore, logger);
const actionRegistry = new TemplateActionRegistry();
const workers = [];