auto commit

edan_v1/hrld/tasks_loop.py

@@ -276,13 +276,13 @@ class globCL(GCLMixin):
 			await asyncio.sleep(self.timeout)
 	def _run_persistent_loop2(self,*a,**kw):
 		p("_run_persistent_loop2:",self,a,kw)
-		self.run_persistent_loop = nop
+		self.run_persistent_loop2 = nop
 		self.rman.persistent_loop_cb()
-		loop = asyncio.get_event_loop()
-		loop.create_task(self.persistent_loop())
+		# loop = asyncio.get_event_loop()
 		# loop.create_task(self.persistent_fast_cb_loop())
-		loop.create_task(self.persistent_fast_cb_loop_min_timeout())
-		self.loop = loop
+		asyncio.ensure_future(self.persistent_loop())
+		asyncio.ensure_future(self.persistent_fast_cb_loop_min_timeout())
+		# self.loop = loop
 
 	def _run_persistent_loop(self,*a,**kw):
 		p("_run_persistent_loop:",self,a,kw)