#airflow
#воздушный поток
Вопрос:
Я пытаюсь получить выходные данные задачи, чтобы я мог присвоить их переменной, но использовать в своей следующей задаче. Будем признательны за любую помощь.. Онлайн-предложение указывает на пример PythonOperator.
Комментарии:
1. вы пробовали пример PythonOperator?
2. @kaxil Я использую пользовательские операторы. В настоящее время я добиваюсь этого, устанавливая значение переменной и используя это значение переменной в моей следующей задаче. PythonOperator позволяет считывать значение xcom, но я ищу подход, при котором я нажимаю значение (xcom), используя пользовательский оператор, и я могу извлечь значение в следующей задаче .. Если я передам идентификатор предыдущей задачи, я смогу достичь этого в operator, но я хотел посмотреть, как я могу достичь этого в том же DAG… любой пример будет полезен