diff --git a/src/Ombi.Schedule/Jobs/Plex/PlexContentSync.cs b/src/Ombi.Schedule/Jobs/Plex/PlexContentSync.cs
index ce53e8162..ed1a035d9 100644
--- a/src/Ombi.Schedule/Jobs/Plex/PlexContentSync.cs
+++ b/src/Ombi.Schedule/Jobs/Plex/PlexContentSync.cs
@@ -252,6 +252,11 @@ namespace Ombi.Schedule.Jobs.Plex
                             contentToAdd.Add(item);
                         }
                     }
+                    if (contentToAdd.Count > 500)
+                    {
+                        await Repo.AddRange(contentToAdd);
+                        contentToAdd = new List<PlexServerContent>();
+                    }
                 }
 
                 if (contentToAdd.Any())
diff --git a/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs b/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs
index 56d484abe..308c74489 100644
--- a/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs
+++ b/src/Ombi.Schedule/Jobs/Plex/PlexEpisodeSync.cs
@@ -99,7 +99,7 @@ namespace Ombi.Schedule.Jobs.Plex
         private async Task GetEpisodes(PlexServers settings, Directory section)
         {
             var currentPosition = 0;
-            var resultCount = settings.EpisodeBatchSize == 0 ? 50 : settings.EpisodeBatchSize;
+            var resultCount = settings.EpisodeBatchSize == 0 ? 150 : settings.EpisodeBatchSize;
             var episodes = await _api.GetAllEpisodes(settings.PlexAuthToken, settings.FullUri, section.key, currentPosition, resultCount);
             _log.LogInformation(LoggingEvents.PlexEpisodeCacher, $"Total Epsiodes found for {episodes.MediaContainer.librarySectionTitle} = {episodes.MediaContainer.totalSize}");