🚧 fix(wip): manual ack is true on non-job

mxchinegod · mxchinegod · commit 4237dbba8fe5 · 2024-02-23T06:02:30.000-05:00
diff --git a/magnet/ic/field.py b/magnet/ic/field.py
@@ -223,7 +223,7 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses
                     , stream=self.stream
                     , queue=self.session
                     , config=self.config
-                    , manual_ack=False
+                    , manual_ack=True
                 )
                 _f('info',
                    f'joined worker queue: {self.session} as {self.node}')

Original file line number	Diff line number	Diff line change
`@@ -223,7 +223,7 @@ async def on(self, category: str = 'no_category', stream: str = 'documents', ses`
`223`	`223`	`, stream=self.stream`
`224`	`224`	`, queue=self.session`
`225`	`225`	`, config=self.config`
`226`		`- , manual_ack=False`
	`226`	`+ , manual_ack=True`
`227`	`227`	`)`
`228`	`228`	`_f('info',`
`229`	`229`	`f'joined worker queue: {self.session} as {self.node}')`