From 4b78c472b12a84f558c0c3ad67c32d0367a0f90f Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Thu, 5 Sep 2019 16:13:18 +0200 Subject: [PATCH] Add sdk:GroupByTaskId(TopologyState) --- fairmq/sdk/Topology.h | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/fairmq/sdk/Topology.h b/fairmq/sdk/Topology.h index 8ffe198c..46a8d530 100644 --- a/fairmq/sdk/Topology.h +++ b/fairmq/sdk/Topology.h @@ -102,6 +102,16 @@ inline TopologyStateByCollection GroupByCollectionId(const TopologyState& topolo return state; } +inline TopologyStateByTask GroupByTaskId(const TopologyState& topologyState) +{ + TopologyStateByTask state; + for (const auto& ds : topologyState) { + state[ds.taskId] = ds; + } + + return state; +} + /** * @class BasicTopology Topology.h * @tparam Executor Associated I/O executor