diff --git a/src/actors.js b/src/actors.js index 93b8b467..649262cd 100644 --- a/src/actors.js +++ b/src/actors.js @@ -944,9 +944,15 @@ async function associateActors(releases, batchId) { }))) .flat(); - logger.debug(releaseActorAssociations); + const validReleaseActorAssociations = releaseActorAssociations.filter(association => association.release_id && association.actor_id); - await bulkInsert('releases_actors', releaseActorAssociations, false); + if (releaseActorAssociations.length > validReleaseActorAssociations.length) { + const invalidReleaseActorAssociations = releaseActorAssociations.filter(association => !association.release_id || !association.actor_id); + + logger.error(invalidReleaseActorAssociations); + } + + await bulkInsert('releases_actors', validReleaseActorAssociations, false); logger.verbose(`Associated ${releaseActorAssociations.length} actors to ${releases.length} scenes`);