Насколько я понимаю, код kubernetespodoperator в потоке воздуха использует python клиентский API для запуска «голых» модулей, отслеживает состояние задач и контейнеров, выполняемых в этих модулях, и возвращает журналы / результаты обратно. к потоку воздуха.
В этом случае сбои / очистка обрабатываются самим воздушным потоком, мне просто интересно, имеет ли смысл иметь KubernetesJobOperator для запуска задачи воздушного потока как kubernetes job , поскольку kubernetes обрабатывает сбои / очистка для нас, и у нас больше контроля и параллельных заданий? Я полагаю, это похоже на то, чтобы поставить больший контроль над воздушным потоком или над kubernetes? Я не знаю ответа, поэтому спрашиваю, что вы, ребята, думаете.