Async watches sync

Taxel · Apr 13, 2024 · e18f73e · e18f73e
1 parent 620b748
commit e18f73e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/plextraktsync/sync.py b/plextraktsync/sync.py
@@ -65,7 +65,7 @@ async def sync(self, walker: Walker, dry_run=False):
             async for movie in walker.find_movies():
                 await self.sync_collection(movie, dry_run=dry_run)
                 await self.sync_ratings(movie, dry_run=dry_run)
-                self.sync_watched(movie, dry_run=dry_run)
+                await self.sync_watched(movie, dry_run=dry_run)
                 if not is_partial:
                     listutil.addPlexItemToLists(movie)
                     if self.config.clear_collected:
@@ -79,7 +79,7 @@ async def sync(self, walker: Walker, dry_run=False):
             async for episode in walker.find_episodes():
                 await self.sync_collection(episode, dry_run=dry_run)
                 await self.sync_ratings(episode, dry_run=dry_run)
-                self.sync_watched(episode, dry_run=dry_run)
+                await self.sync_watched(episode, dry_run=dry_run)
                 if not is_partial:
                     listutil.addPlexItemToLists(episode)
                     if self.config.clear_collected:
@@ -172,7 +172,7 @@ async def sync_ratings(self, m: Media, dry_run=False):
             if not dry_run:
                 m.plex_rate()
 
-    def sync_watched(self, m: Media, dry_run=False):
+    async def sync_watched(self, m: Media, dry_run=False):
         if not self.config.sync_watched_status:
             return