Taskflow support for HITLOperators #52203
Description
Body
Once #52349 is done, we'll need to check how we can achieve something like
@task.branch
def choose_branch(result):
if result > 0.5:
return ['task_a', 'task_b']
return ['task_c']but for HITLBranchOperator
@task.hitl_branch(subject="Choose one", options=["1", "2", "3", "4', "5"])
def choose_branch(context: Context, event: dict[str, Any]):
...We want to achieve something similar to the execute_complete in the last part of this description #52349 (comment)
For more details on how HITLOperator works and could be tested, please refer to the description of #52868 and #52868 (comment)
Committer
- I acknowledge that I am a maintainer/committer of the Apache Airflow project.