Added consumer, executor logic, subtasks

Added logic for consumers executing tasks, aggregate tasks that
contain child tasks (single level), etc.