Не знаю как тут в amp php
но есть такой интерфейс как
https://amphp.org/parallel#tasks
В reactPHP есть promise в которые ты передаешь через
Deferred в метод resolve(данные которые тебе надо обработать) : PromiseInterface.
Попробуй в RunContentJobTask имплементировать Task и запустить в методе run выполнения метода save.
не знаю может у тебя уже так и сделано.