2 files changed, 6 insertions, 5 deletions
diff --git a/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix b/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix
index 3f8363a..33ccc25 100644
--- a/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix
+++ b/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix
@@ -4,7 +4,7 @@ let
cfg = config.services.matrix-synapse;
workerLib = import ../lib.nix;
dbGroup = "medium";
-# streamWriterType = "account_data";
+ # streamWriterType = "account_data";
workers = lib.range 0 (cfg.accountDataStreamWriters - 1);
workerName = "account_data_stream_writer";
tasks = [ "stream_account_data" ];
@@ -12,7 +12,8 @@ let
in
let
enabledResources = lib.attrNames workerRoutes;
- streamTypes = []
+ streamTypes =
+ [ ]
++ lib.optional (lib.elem "stream_account_data" tasks) "account_data"
++ lib.optional (lib.elem "stream_presence" tasks) "presence"
++ lib.optional (lib.elem "stream_push_rules" tasks) "push_rules"
@@ -36,7 +37,7 @@ in
);
#stream_writers.${streamWriterType} = lib.map (index: "${workerName}-${toString index}") workers;
-# stream_writers = lib.listToA
+ # stream_writers = lib.listToA
# map `streams` to `workers`
stream_writers = lib.listToAttrs (
lib.map (stream: {
diff --git a/modules/software-templates/synapse-workers/stream-writers/event-stream-writer.nix b/modules/software-templates/synapse-workers/stream-writers/event-stream-writer.nix
index 6abce3f..3c72d46 100644
--- a/modules/software-templates/synapse-workers/stream-writers/event-stream-writer.nix
+++ b/modules/software-templates/synapse-workers/stream-writers/event-stream-writer.nix
@@ -7,8 +7,8 @@ let
workers = lib.range 0 (cfg.eventStreamWriters - 1);
workerName = "event_stream_writer";
tasks = [ ];
- workerRoutes = {};
- enabledResources = [];
+ workerRoutes = { };
+ enabledResources = [ ];
in
{
config = lib.mkIf (cfg.eventStreamWriters > 0) {
|
