def METHOD_NAME(self, current_worker_task):
    g, result = self.mock_group(self.add.s(2), self.add.s(4))
    self.task(g.tasks, result, result.id, (2,)).results
    g.tasks[0].clone().apply_async.assert_called_with(
        group_id=result.id, producer=self.app.producer_or_acquire(),
        add_to_parent=False,
    )
    current_worker_task.add_trail.assert_called_with(result)