1 files changed, 4 insertions, 3 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: {
|