'Passes entries to the target task(s) configured for this connection
:return:'

def run_tasks(self):

    tasks = self.config.get(u'task')
    tasks_re = self.config.get(u'task_re')
    if tasks:
        if isinstance(tasks, basestring):
            tasks = [tasks]
        log.debug(u'Injecting    %d    entries    into    tasks    %s', len(self.entry_queue), u',    '.join(tasks))
        manager.execute(options={u'tasks': tasks, u'cron': True, u'inject': self.entry_queue, u'allow_manual': True}, priority=5)
    if tasks_re:
        tasks_entry_map = {}
        for entry in self.entry_queue:
            matched = False
            for (task, config) in tasks_re.items():
                if isinstance(config, dict):
                    config = [config]
                for c in config:
                    if re.search(c[u'regexp'], entry.get(c[u'field'], u''), re.IGNORECASE):
                        matched = True
                        if (not tasks_entry_map.get(task)):
                            tasks_entry_map[task] = []
                        tasks_entry_map[task].append(entry)
            if (not matched):
                log.debug(u'Entry    "%s"    did    not    match    any    task    regexp.', entry[u'title'])
        for (task, entries) in tasks_entry_map.items():
            log.debug(u'Injecting    %d    entries    into    task    "%s"', len(entries), task)
            manager.execute(options={u'tasks': [task], u'cron': True, u'inject': entries, u'allow_manual': True}, priority=5)
    self.entry_queue = []
