@abstractmethod<EOL><INDENT>def choose_tasks(self, values):<DEDENT>
pass<EOL>
Implements a custom stream grouping

        :param values: the values to group on
        :rtype: list of int
        :return: list of task ids to which these values are emitted