bugfix

test/server.py

@@ -0,0 +1,13 @@
+import asyncio
+from appPublic.worker import get_event_loop
+from longtasks.longtasks import LongTasks
+
+if __name__ == '__main__':
+	async def main(lt):
+		while True:
+			await asyncio.sleep(10)
+
+	lt = LongTasks('redis://127.0.0.1:6379', 'test')
+	loop = get_event_loop()
+	loop.create_task(lt.run())
+	loop.run_until_complete(main(lt))

test/submit.py

@@ -0,0 +1,21 @@
+import asyncio
+from appPublic.worker import get_event_loop
+from longtasks.longtasks import LongTasks
+
+if __name__ == '__main__':
+	async def main(lt):
+		await lt.start_redis()
+		payload = { 
+			"task": f"task my test"
+		}
+		x = await lt.submit_task(payload)
+		while True:
+			s = await lt.get_status(x['task_id'])
+			print(s)
+			if s['status'] in ['FAILED', 'SUCCEEDED']:
+				break;
+			await asyncio.sleep(1)
+
+	lt = LongTasks('redis://127.0.0.1:6379', 'test')
+	loop = get_event_loop()
+	loop.run_until_complete(main(lt))