Make walk_movie and walk_episode in plugins async

Taxel · Apr 16, 2024 · dbf5bbd · dbf5bbd
1 parent 24b2bc2
commit dbf5bbd
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/plextraktsync/sync/AddCollectionPlugin.py b/plextraktsync/sync/AddCollectionPlugin.py
@@ -23,11 +23,11 @@ def factory(cls, sync: Sync):
         return cls()
 
     @hookimpl
-    def walk_movie(self, movie: Media, dry_run: bool):
+    async def walk_movie(self, movie: Media, dry_run: bool):
         self.sync_collection(movie, dry_run=dry_run)
 
     @hookimpl
-    def walk_episode(self, episode: Media, dry_run: bool):
+    async def walk_episode(self, episode: Media, dry_run: bool):
         self.sync_collection(episode, dry_run=dry_run)
 
     def sync_collection(self, m: Media, dry_run: bool):

diff --git a/plextraktsync/sync/ClearCollectedPlugin.py b/plextraktsync/sync/ClearCollectedPlugin.py
@@ -45,7 +45,7 @@ def fini(self, dry_run: bool):
         self.clear_collected(self.trakt.episodes_collection, self.episode_trakt_ids, dry_run=dry_run)
 
     @hookimpl
-    def walk_movie(self, movie: Media):
+    async def walk_movie(self, movie: Media):
         if self.is_partial:
             return
 

diff --git a/plextraktsync/sync/SyncRatingsPlugin.py b/plextraktsync/sync/SyncRatingsPlugin.py
@@ -30,11 +30,11 @@ def factory(cls, sync: Sync):
         return cls(config=sync.config)
 
     @hookimpl
-    def walk_movie(self, movie: Media, dry_run: bool):
+    async def walk_movie(self, movie: Media, dry_run: bool):
         self.sync_ratings(movie, dry_run=dry_run)
 
     @hookimpl
-    def walk_episode(self, episode: Media, dry_run: bool):
+    async def walk_episode(self, episode: Media, dry_run: bool):
         self.sync_ratings(episode, dry_run=dry_run)
 
         if episode.show:

diff --git a/plextraktsync/sync/SyncWatchedPlugin.py b/plextraktsync/sync/SyncWatchedPlugin.py
@@ -27,11 +27,11 @@ def factory(cls, sync: Sync):
         return cls(config=sync.config)
 
     @hookimpl
-    def walk_movie(self, movie: Media, dry_run: bool):
+    async def walk_movie(self, movie: Media, dry_run: bool):
         self.sync_watched(movie, dry_run=dry_run)
 
     @hookimpl
-    def walk_episode(self, episode: Media, dry_run: bool):
+    async def walk_episode(self, episode: Media, dry_run: bool):
         self.sync_watched(episode, dry_run=dry_run)
 
     def sync_watched(self, m: Media, dry_run: bool):

diff --git a/plextraktsync/sync/WatchProgressPlugin.py b/plextraktsync/sync/WatchProgressPlugin.py
@@ -28,11 +28,11 @@ def factory(cls, sync: Sync):
         return cls(sync.trakt)
 
     @hookimpl
-    def walk_movie(self, movie: Media, dry_run: bool):
+    async def walk_movie(self, movie: Media, dry_run: bool):
         self.sync_progress(movie, dry_run=dry_run)
 
     @hookimpl
-    def walk_episode(self, episode: Media, dry_run: bool):
+    async def walk_episode(self, episode: Media, dry_run: bool):
         self.sync_progress(episode, dry_run=dry_run)
 
     def sync_progress(self, m: Media, dry_run=False):