🚧 fix(wip): nope we don't need this nats code does it for us.

mxchinegod · mxchinegod · commit 4f261053fcd4 · 2024-02-23T10:51:30.000-05:00
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -206,7 +206,6 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses
         self.durable = f'{self.node}_job' if job else self.node
         self.config = ConsumerConfig(
             ack_policy="explicit"
-            , deliver_group=self.session
             , max_ack_pending=bandwidth
             , ack_wait=3600
         )

Original file line number	Diff line number	Diff line change
`@@ -206,7 +206,6 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses`
`206`	`206`	`self.durable = f'{self.node}_job' if job else self.node`
`207`	`207`	`self.config = ConsumerConfig(`
`208`	`208`	`ack_policy="explicit"`
`209`		`- , deliver_group=self.session`
`210`	`209`	`, max_ack_pending=bandwidth`
`211`	`210`	`, ack_wait=3600`
`212`	`211`	`)`