| 1619 | } |
| 1620 | |
| 1621 | void dropTaskGroup(const TaskGroupInfo& taskGroup) |
| 1622 | { |
| 1623 | TaskState taskState = |
| 1624 | protobuf::frameworkHasCapability( |
| 1625 | frameworkInfo.get(), FrameworkInfo::Capability::PARTITION_AWARE) |
| 1626 | ? TASK_DROPPED |
| 1627 | : TASK_LOST; |
| 1628 | |
| 1629 | foreach (const TaskInfo& task, taskGroup.tasks()) { |
| 1630 | forward(createTaskStatus(task.task_id(), taskState)); |
| 1631 | } |
| 1632 | } |
| 1633 | |
| 1634 | enum State |
| 1635 | { |
nothing calls this directly
no test coverage detected