🐛 fix(bug): workqueue mandate was invalid on subject-add

Prismadic · Mar 12, 2024 · c7cee7e · c7cee7e
1 parent cda36ad
commit c7cee7e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -62,7 +62,9 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', cre
                             [x.config.subjects for x in streams if x.config.name == self.stream], [])
                         subjects.append(self.category)
                         await self.js.update_stream(StreamConfig(
-                            name=self.stream, subjects=subjects, retention='workqueue'
+                            name=self.stream
+                            , subjects=subjects
+                            , retention='workqueue' if workgroup else None
                         ))
                         _f("success",
                            f'created [{self.category}] on\n🛰️ stream: {self.stream}')