ansible operator support

[liuzheng]

Description

Airflow running ansible playbook like AWX, I will create PR, but I need help to make it more airflow pluginable.

If you think it is a good job, I can provide more example dags and documents

@task()
def prepare_data():
    return "hello.yaml"
 
@task() 
def prepare_inventory():
    return {} # ansible inventory
 
@task.ansible()
def hello(playbook,inventory): # pylint: disable=unused-argument
    """hello"""
    context = get_current_context()
    task_log.debug(context["ansible_return"])
    return context["ansible_return"]
 
@dag(
...
)
def main():
    """main"""
    playbook_data = prepare_data()
    inventory = prepare_inventory()
    hello(playbook=playbook_data,inventory=inventory)

Use case/motivation

run ansible playbook

Related issues

No response

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[boring-cyborg]

Thanks for opening your first issue here! Be sure to follow the issue template! If you are willing to raise PR to address this issue please do so, no need to wait for approval.