auto commit

edan_v1/hrld/tasks_loop.py

@@ -284,6 +284,17 @@ class globCL(GCLMixin):
 		asyncio.ensure_future(self.persistent_fast_cb_loop_min_timeout())
 		# self.loop = loop
 
+
+	def _run_persistent_loop3(self,*a,**kw):
+		p("_run_persistent_loop3:",self,a,kw)
+		loop = asyncio.new_event_loop()
+		self.run_persistent_loop = nop
+		self.rman.persistent_loop_cb()
+		loop.create_task(self.persistent_loop())
+		# loop.create_task(self.persistent_fast_cb_loop())
+		loop.create_task(self.persistent_fast_cb_loop_min_timeout())
+		self.loop = loop
+
 	def _run_persistent_loop(self,*a,**kw):
 		p("_run_persistent_loop:",self,a,kw)
 		loop = asyncio.get_event_loop()
@@ -295,6 +306,7 @@ class globCL(GCLMixin):
 		self.loop = loop
 	run_persistent_loop = _run_persistent_loop
 	run_persistent_loop2 = _run_persistent_loop2
+	run_persistent_loop3 = _run_persistent_loop3
 
 
 	def sync_dev_group_discard(self,*a,**kw):