Skip to content

Commit c7cee7e

Browse files
committed
🐛 fix(bug): workqueue mandate was invalid on subject-add
1 parent cda36ad commit c7cee7e

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

magnet/ic/field.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,9 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', cre
6262
[x.config.subjects for x in streams if x.config.name == self.stream], [])
6363
subjects.append(self.category)
6464
await self.js.update_stream(StreamConfig(
65-
name=self.stream, subjects=subjects, retention='workqueue'
65+
name=self.stream
66+
, subjects=subjects
67+
, retention='workqueue' if workgroup else None
6668
))
6769
_f("success",
6870
f'created [{self.category}] on\n🛰️ stream: {self.stream}')

0 commit comments

Comments
 (0)