Skip to content

Commit

Permalink
Fix gather usage
Browse files Browse the repository at this point in the history
  • Loading branch information
glensc committed Apr 13, 2024
1 parent 33080a8 commit e6294cc
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions plextraktsync/sync.py
Original file line number Diff line number Diff line change
Expand Up @@ -64,11 +64,11 @@ async def sync(self, walker: Walker, dry_run=False):
if self.config.need_library_walk:
movie_trakt_ids = set()
async for movie in walker.find_movies():
await asyncio.gather(*[
await asyncio.gather(
self.sync_collection(movie, dry_run=dry_run),
self.sync_ratings(movie, dry_run=dry_run),
self.sync_watched(movie, dry_run=dry_run),
])
)
if not is_partial:
listutil.addPlexItemToLists(movie)
if self.config.clear_collected:
Expand All @@ -80,11 +80,11 @@ async def sync(self, walker: Walker, dry_run=False):
shows = set()
episode_trakt_ids = set()
async for episode in walker.find_episodes():
await asyncio.gather(*[
await asyncio.gather(
self.sync_collection(episode, dry_run=dry_run),
self.sync_ratings(episode, dry_run=dry_run),
self.sync_watched(episode, dry_run=dry_run),
])
)
if not is_partial:
listutil.addPlexItemToLists(episode)
if self.config.clear_collected:
Expand Down

0 comments on commit e6294cc

Please sign in to comment.