Merge pull request #16 from mwhahaha/ansible-task-options

Add task_options to ansible runner tasks

schema/service.yaml

@@ -140,6 +140,8 @@ definitions:
         type: string
       runner_options:
         type: object
+      task_options:
+        type: object
       global_fact_cache:
         type: boolean
     required:

task_core/tasks.py

@@ -216,6 +216,10 @@ def working_dir(self) -> str:
     def runner_options(self) -> dict:
         return self._data.get("runner_options", {})
 
+    @property
+    def task_options(self) -> dict:
+        return self._data.get("task_options", {})
+
     @property
     def global_fact_cache(self) -> bool:
         return self._data.get("global_fact_cache", True)
@@ -311,7 +315,10 @@ def execute(self, *args, **kwargs) -> list:
         runner_config.prepare()
         # TODO: the call back needs to be overridden here if you want something
         # other than the default.
-        # runner_config.env["ANSIBLE_STDOUT_CALLBACK"] = "tripleo_dense"
+        if self.task_options and "ANSIBLE_STDOUT_CALLBACK" in self.task_options:
+            runner_config.env["ANSIBLE_STDOUT_CALLBACK"] = self.task_options[
+                "ANSIBLE_STDOUT_CALLBACK"
+            ]
 
         # By default ansible-runner forces a per-execution fact cache but we
         # want to share fact caches between our tasks. This can be disabled