samuelkhtu commented on issue #8525: URL: https://github.com/apache/airflow/issues/8525#issuecomment-629029045
Hey @jeffolsi , quick question for you. In the existing Airflow Python Branching Operator, the python callback function will return the 'task_id' or list of 'tasl_ids' for selecting the branching to follow. I am just wondering if you would like to use the SQL query to select the branches as well? For example, the SQL query "SELECT 'branch_a', 'branch_b' will return 2 columns and the SQLBranchOperator will follow branch_a and branch_b. (branch_a and branch_b are task_ids within the DAG) Or you expect the SQL query to return multiple rows, each row will represent the task_id within the DAG? Thanks ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
