🧲 feat(release): distributed indexing is perfected, for now

mxchinegod · mxchinegod · commit 945bc7c07b80 · 2024-03-08T12:59:48.000-05:00
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -217,7 +217,7 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses
             )
             try:
                 self.sub = await self.js.pull_subscribe(
-                    durable=self.durable
+                    durable=self.session
                     , subject=self.category
                     , stream=self.stream
                     , config=self.config

Original file line number	Diff line number	Diff line change
`@@ -217,7 +217,7 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses`
`217`	`217`	`)`
`218`	`218`	`try:`
`219`	`219`	`self.sub = await self.js.pull_subscribe(`
`220`		`- durable=self.durable`
	`220`	`+ durable=self.session`
`221`	`221`	`, subject=self.category`
`222`	`222`	`, stream=self.stream`
`223`	`223`	`, config=self.config`