cleared.py

class Tasky:
    def __init__(self, task):
        self.results = {}
        
    def add_result(self, host, result):
        self.results[host] = result
        print "task (%s), results(%s) count(%s)" % (id(self), id(self.results), len(self.results))

class CallbackModule(object):
    
    
    def __init__(self):
        self.tasks = []
        self.current = None

    def playbook_on_task_start(self, name, is_conditional):
    
        self.current = Tasky(self.task)
        self.tasks.append(self.current)

    def playbook_on_stats(self, stats):
        
       for task in self.tasks:
           print "task name %s" % (task.results)

    def runner_on_ok(self, host, res):
        if self.current:
            print "task (%s)" % (id(self.current))
            self.current.add_result(host, res)
        

cleared.yml

- hosts: all
  connection: local
  
  tasks:
    
    - debug: msg='stored for each host'