Не, стоп, airflow ,запускает Даг, а в нем что?
Ну, просто я привык, что в даге идёт вызов функции в постгрес операторе. Никто, конечно, не мешает запихнуть всё в код дага, но зачем?)
и чего, ты не можешь понять, как сделать так, чтобы шаг был доступен?