Merge pull request #14 from andersinno/asyncio-run

suutari-ai · web-flow · commit 14ee29beaf90 · 2025-01-10T16:39:55.000+02:00
sync scripts: Use asyncio.run instead of get_event_loop
diff --git a/src/passari_workflow/scripts/sync_attachments.py b/src/passari_workflow/scripts/sync_attachments.py
@@ -223,8 +223,7 @@ async def sync_attachments(offset=0, limit=None, save_progress=False):
 def cli(offset, limit, save_progress):
     connect_db()
 
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(
+    asyncio.run(
         sync_attachments(
             offset=offset, limit=limit, save_progress=save_progress
         )
diff --git a/src/passari_workflow/scripts/sync_objects.py b/src/passari_workflow/scripts/sync_objects.py
@@ -221,8 +221,7 @@ async def sync_objects(offset=0, limit=None, save_progress=False):
 def cli(offset, limit, save_progress):
     connect_db()
 
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(
+    asyncio.run(
         sync_objects(
             offset=offset, limit=limit, save_progress=save_progress
         )

Original file line number	Diff line number	Diff line change
`@@ -223,8 +223,7 @@ async def sync_attachments(offset=0, limit=None, save_progress=False):`
`223`	`223`	`def cli(offset, limit, save_progress):`
`224`	`224`	`connect_db()`
`225`	`225`
`226`		`- loop = asyncio.get_event_loop()`
`227`		`- loop.run_until_complete(`
	`226`	`+ asyncio.run(`
`228`	`227`	`sync_attachments(`
`229`	`228`	`offset=offset, limit=limit, save_progress=save_progress`
`230`	`229`	`)`
Original file line number	Diff line number	Diff line change
`@@ -221,8 +221,7 @@ async def sync_objects(offset=0, limit=None, save_progress=False):`
`221`	`221`	`def cli(offset, limit, save_progress):`
`222`	`222`	`connect_db()`
`223`	`223`
`224`		`- loop = asyncio.get_event_loop()`
`225`		`- loop.run_until_complete(`
	`224`	`+ asyncio.run(`
`226`	`225`	`sync_objects(`
`227`	`226`	`offset=offset, limit=limit, save_progress=save_progress`
`228`	`227`	`)`