uploads, получаеться массив файлов, которые нужно обработать. Этот массив разделяю между воркерами - cluster.fork() - и каждому припадает свое задание. Они паралельно начинают исполняться. Их задача свою часть - массив - пропустить через функцию compress она создает папку images и сжимает файлы, потом после сжатия нужно пройти через функцию add, оно берет файлы из папки images и подписывает их красной строчкой - sample watermark.
Так должно работать: такой порядок исполнения.
Но у меня получаеться, что функция подписи - add - она иногда срабатывает раньше чем compress.
( Там проверка на наличие файла в ней: exists )
И поэтому файлы не подписывает.
И еще некоторые файлы теряються: не попадают в папку images. На входе их 73, а на выходе 55-57.
Как сделать так чтобы функция add запускалася после того как функция compress полностью завершит свою работа ---- как огранизовать правильный порядок исполнения функцию?
нужно переделать Fal.compress, чтобы возвращался промис и запускать add только когда выполнится сжатие
Обсуждают сегодня