diff --git a/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs b/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs
index c6630ee0e..56d484abe 100644
--- a/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs
+++ b/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs
@@ -101,17 +101,20 @@ namespace Ombi.Schedule.Jobs.Plex
             var currentPosition = 0;
             var resultCount = settings.EpisodeBatchSize == 0 ? 50 : settings.EpisodeBatchSize;
             var episodes = await _api.GetAllEpisodes(settings.PlexAuthToken, settings.FullUri, section.key, currentPosition, resultCount);
-            var currentData = _repo.GetAllEpisodes().AsNoTracking();
             _log.LogInformation(LoggingEvents.PlexEpisodeCacher, $"Total Epsiodes found for {episodes.MediaContainer.librarySectionTitle} = {episodes.MediaContainer.totalSize}");
 
-            await ProcessEpsiodes(episodes, currentData);
+            // Delete all the episodes because we cannot uniquly match an episode to series every time, 
+            // see comment below.
+            await _repo.ExecuteSql("DELETE FROM PlexEpisode");
+
+            await ProcessEpsiodes(episodes);
             currentPosition += resultCount;
 
             while (currentPosition < episodes.MediaContainer.totalSize)
             {
                 var ep = await _api.GetAllEpisodes(settings.PlexAuthToken, settings.FullUri, section.key, currentPosition,
                     resultCount);
-                await ProcessEpsiodes(ep, currentData);
+                await ProcessEpsiodes(ep);
                 _log.LogInformation(LoggingEvents.PlexEpisodeCacher, $"Processed {resultCount} more episodes. Total Remaining {episodes.MediaContainer.totalSize - currentPosition}");
                 currentPosition += resultCount;
             }
@@ -121,7 +124,7 @@ namespace Ombi.Schedule.Jobs.Plex
             await _repo.SaveChangesAsync();
         }
 
-        private async Task ProcessEpsiodes(PlexContainer episodes, IQueryable<PlexEpisode> currentEpisodes)
+        private async Task ProcessEpsiodes(PlexContainer episodes)
         {
             var ep = new HashSet<PlexEpisode>();
 
@@ -131,12 +134,13 @@ namespace Ombi.Schedule.Jobs.Plex
                 // We have the parent and grandparent rating keys to link up to the season and series
                 //var metadata = _api.GetEpisodeMetaData(server.PlexAuthToken, server.FullUri, episode.ratingKey);
 
-                var epExists = currentEpisodes.Any(x => episode.ratingKey == x.Key &&
-                                                          episode.grandparentRatingKey == x.GrandparentKey);
-                if (epExists)
-                {
-                    continue;
-                }
+                // This does seem to work, it looks like we can somehow get different rating, grandparent and parent keys with episodes. Not sure how.
+                //var epExists = currentEpisodes.Any(x => episode.ratingKey == x.Key &&
+                //                                          episode.grandparentRatingKey == x.GrandparentKey);
+                //if (epExists)
+                //{
+                //    continue;
+                //}
 
                 ep.Add(new PlexEpisode
                 {
diff --git a/src/Ombi.Store/Repository/IRepository.cs b/src/Ombi.Store/Repository/IRepository.cs
index 9df78f083..ed5ed28c5 100644
--- a/src/Ombi.Store/Repository/IRepository.cs
+++ b/src/Ombi.Store/Repository/IRepository.cs
@@ -22,5 +22,7 @@ namespace Ombi.Store.Repository
         IIncludableQueryable<TEntity, TProperty> Include<TEntity, TProperty>(
             IQueryable<TEntity> source, Expression<Func<TEntity, TProperty>> navigationPropertyPath)
             where TEntity : class;
+
+        Task ExecuteSql(string sql);
     }
 }
\ No newline at end of file
diff --git a/src/Ombi.Store/Repository/Repository.cs b/src/Ombi.Store/Repository/Repository.cs
index f7c12709f..b4b9f8e93 100644
--- a/src/Ombi.Store/Repository/Repository.cs
+++ b/src/Ombi.Store/Repository/Repository.cs
@@ -72,6 +72,11 @@ namespace Ombi.Store.Repository
             return source.Include(navigationPropertyPath);
         }
 
+        public async Task ExecuteSql(string sql)
+        {
+            await _ctx.Database.ExecuteSqlCommandAsync(sql);
+        }
+
 
         private bool _disposed;
         // Protected implementation of Dispose pattern.