diff --git a/plextraktsync/sync/AddCollectionPlugin.py b/plextraktsync/sync/AddCollectionPlugin.py
index ed3eaeeb09..a3da27fc5b 100644
--- 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
index 2a70f0961b..8188dad219 100644
--- 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
index cd6287015f..5d38f5459c 100644
--- 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
index 1fa9d0e98e..b570341d3c 100644
--- 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
index cd79738d9f..a4535fee32 100644
--- 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):