diff --git a/test/server.py b/test/server.py new file mode 100644 index 0000000..e5f5c81 --- /dev/null +++ b/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)) diff --git a/test/submit.py b/test/submit.py new file mode 100644 index 0000000..96ad799 --- /dev/null +++ b/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))