# -*- coding: utf-8 -*-
# Copyright (c) 2013, 2017, System Engineering Software Society
# All rights reserved.
#
# Redistribution and use in source and binary forms, with or without
# modification, are permitted provided that the following conditions are met:
# * Redistributions of source code must retain the above copyright
# notice, this list of conditions and the following disclaimer.
# * Redistributions in binary form must reproduce the above copyright
# notice, this list of conditions and the following disclaimer in the
# documentation and/or other materials provided with the distribution.
# * Neither the name of the System Engineering Software Society nor the
# names of its contributors may be used to endorse or promote products
# derived from this software without specific prior written permission.
#
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
# AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
# ARE DISCLAIMED.
# IN NO EVENT SHALL SYSTEM ENGINEERING SOFTWARE SOCIETY BE LIABLE FOR ANY
# DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
# (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
# LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
# ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
from __future__ import (print_function, division, unicode_literals,
absolute_import)
import itertools
import six
from sympathy.api import node as synode
from sympathy.api import adaf, table
from sympathy.api.nodeconfig import (Port, Ports, Tag, Tags, deprecated_node,
adjust)
from sylib import sort as sort_util
def append_execute(node_context):
input_element = node_context.input['port1']
input_list = node_context.input['port2']
output_list = node_context.output['port3']
output_list.extend(input_list)
output_list.append(input_element)
def extend_execute(node_context):
input_list1 = node_context.input['port1']
input_list2 = node_context.input['port2']
output_list = node_context.output['port3']
output_list.extend(input_list1)
output_list.extend(input_list2)
def extend(list1, list2):
for elem in list2:
list1.append(elem)
def match_length(node_context, fill_data):
input_list1 = node_context.input['guide']
input_list2 = node_context.input['input']
output_list = node_context.output['output']
parameter_root = synode.parameters(node_context.parameters)
len1 = len(input_list1)
len2 = len(input_list2)
fill = parameter_root['fill'].selected
if fill == 'Last value' and len2:
fill_data = input_list2[len2 - 1]
if len1 >= len2:
extend(output_list, input_list2)
extend(output_list, itertools.repeat(fill_data, len1 - len2))
else:
extend(output_list, itertools.islice(input_list2, len1))
class SuperNode(object):
author = "Alexander Busck <alexander.busck@sysess.org>"
copyright = "(C) 2013 System Engineering Software Society"
version = '1.0'
class Index(SuperNode):
description = 'Get an item from a list'
parameters = synode.parameters()
parameters.set_list(
'combo', ['0'], label="Index", value=[0],
description='List indexes.',
editor=synode.Util.combo_editor().value())
class ADAFNode(SuperNode):
outputs = Ports([Port.ADAFs('Output ADAFs', name='port3')])
class TableNode(SuperNode):
outputs = Ports([Port.Tables('Output Tables', name='port3')])
class TextNode(SuperNode):
outputs = Ports([Port.Texts('Output Texts', name='port3')])
[docs]@deprecated_node('1.5.0', 'Append List')
class AppendADAF(ADAFNode, synode.Node):
"""
Append ADAF to a list of ADAFs.
:Inputs:
**First** : ADAF
ADAF to be appended to the list on the lower port.
**Second** : ADAFs
List of ADAFs that the ADAF on the upper port to be appended to.
:Outputs:
**Output** : ADAFs
List of ADAFs that includes all incoming ADAFs. The ADAF
on the upper port is located as the last element of the list.
:Opposite node:
:Ref. nodes: :ref:`Extend ADAF`
"""
name = 'Append ADAF'
description = 'Append to a list'
icon = 'list_append.svg'
nodeid = 'org.sysess.sympathy.list.appendadaf'
inputs = Ports([
Port.ADAF('ADAF to be appended', name='port1'),
Port.ADAFs('Appended ADAFs', name='port2')])
def execute(self, node_context):
append_execute(node_context)
[docs]@deprecated_node('1.5.0', 'Append List')
class AppendTable(TableNode, synode.Node):
"""
Append Table to a list of Tables.
:Inputs:
**First** : Table
Table to be appended to the list on the lower port.
**Second** : Tables
List of Tables that the Table on the upper port to be appended to.
:Outputs:
**Output** : Tables
List of Tables that includes all incoming Tables. The Table
on the upper port is located as the last element of the list.
:Opposite node:
:Ref. nodes: :ref:`Extend Table`
"""
name = 'Append Table'
description = 'Append to a list'
icon = 'list_append.svg'
nodeid = 'org.sysess.sympathy.list.appendtable'
inputs = Ports([
Port.Table('Table to be appended', name='port1'),
Port.Tables('Appended Tables', name='port2')])
def execute(self, node_context):
append_execute(node_context)
[docs]@deprecated_node('1.5.0', 'Append List')
class AppendText(TextNode, synode.Node):
"""
Append Text to a list of Texts.
:Inputs:
**First** : Text
Text to be appended to the list on the lower port.
**Second** : Texts
List of Texts that the Text on the upper port to be appended to.
:Outputs:
**Output** : Texts
List of Texts that includes all incoming Texts. The Text
on the upper port is located as the last element of the list.
:Opposite node:
:Ref. nodes: :ref:`Extend Text`
"""
name = 'Append Text'
description = 'Append to a list'
icon = 'list_append.svg'
nodeid = 'org.sysess.sympathy.list.appendtext'
inputs = Ports([
Port.Text('Text to be appended', name='port1'),
Port.Texts('Appended Texts', name='port2')])
def execute(self, node_context):
append_execute(node_context)
class SuperNodeGeneric(synode.Node):
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
copyright = '(C) 2015 System Engineering Software Society'
version = '1.0'
tags = Tags(Tag.Generic.List, Tag.DataProcessing.List)
[docs]@deprecated_node('1.5.0', 'Append List')
class AppendListOld(SuperNodeGeneric):
"""Create a list with the items from list (input) followed by item."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Append List Old'
nodeid = 'org.sysess.sympathy.list.appendlist'
icon = 'append_list.svg'
inputs = Ports([
Port.Custom('<a>', 'The Item to be appended', name='item'),
Port.Custom('[<a>]', 'Appended List', name='list')])
outputs = Ports([
Port.Custom('[<a>]', 'Appended List', name='list')])
def execute(self, node_context):
result = node_context.output['list']
result.extend(node_context.input['list'])
result.append(node_context.input['item'])
[docs]class AppendList(SuperNodeGeneric):
"""Create a list with the items from list (input) followed by item."""
name = 'Append List'
nodeid = 'org.sysess.sympathy.list.appendlistnew'
icon = 'append_list_new.svg'
tags = Tags(Tag.Generic.List, Tag.DataProcessing.List)
inputs = Ports([
Port.Custom('[<a>]', 'Appended List', name='list'),
Port.Custom('<a>', 'The Item to be appended', name='item',
n=(1, None, 1))])
outputs = Ports([
Port.Custom('[<a>]', 'Appended List', name='list')])
def execute(self, node_context):
result = node_context.output['list']
result.extend(node_context.input['list'])
for item in node_context.input.group('item'):
result.append(item)
[docs]class ItemToList(SuperNodeGeneric):
"""Create a single item list containing item."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Item to List'
nodeid = 'org.sysess.sympathy.list.itemtolist'
icon = 'item_to_list.svg'
inputs = Ports([
Port.Custom('<a>', 'Input Item', name='item', n=(1,))])
outputs = Ports([
Port.Custom('[<a>]', 'Item as List', name='list')])
parameters = synode.parameters()
parameters.set_integer(
'n', label='Repeat number of times', value=1,
description='Choose number of times to repeat items.')
def execute(self, node_context):
result = node_context.output['list']
n = node_context.parameters['n'].value
if n <= 0:
n = 1
for _ in range(n):
for item in node_context.input.group('item'):
result.append(item)
[docs]class GetItemList(SuperNodeGeneric):
"""Get one item in list by index."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Get Item List'
nodeid = "org.sysess.sympathy.list.getitemlist"
inputs = Ports(
[Port.Custom('[<a>]', 'Input List', name='list')])
outputs = Ports(
[Port.Custom('<a>', 'Output selected Item from List', name='item'),
Port.Custom('[<a>]', 'Output non-selected Items from List',
name='rest', n=(0, 1, 0))])
icon = 'get_item_list.svg'
parameters = synode.parameters()
parameters.set_list(
'index', ['0'], label='Index', value=[0],
description='Choose item index in list.',
editor=synode.Util.combo_editor().value())
def adjust_parameters(self, node_context):
adjust(node_context.parameters['index'], node_context.input[0],
lists='index')
def execute(self, node_context):
index = node_context.parameters['index'].value[0]
node_context.output['item'].source(node_context.input['list'][index],
shallow=True)
for rest in node_context.output.group('rest'):
for i, item in enumerate(node_context.input['list']):
if i != index:
rest.append(item)
@deprecated_node('1.5.0', 'Get Item List')
class GetItemListUpdate(GetItemList):
nodeid = None
name = None
def update_parameters(self, parameters):
if 'index' not in parameters:
parameters.set_list(
'index', ['0'], label='Index', value=[0],
description='Choose item index in list.',
editor=synode.Util.combo_editor().value())
if 'combo' in parameters:
combo = parameters['combo']
parameters['index'].list = combo.list
parameters['index'].value = combo.value
del parameters['combo']
[docs]class GetItemADAF(GetItemListUpdate):
name = 'Get Item ADAF'
nodeid = "org.sysess.sympathy.list.getitemadaf"
[docs]class GetItemTable(GetItemListUpdate):
name = 'Get Item Table'
nodeid = "org.sysess.sympathy.list.getitemtable"
[docs]class GetItemText(GetItemListUpdate):
name = 'Get Item Text'
nodeid = "org.sysess.sympathy.list.getitemtext"
[docs]class PadList(SuperNodeGeneric):
"""Pad a list to match another list."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Pad List'
description = 'Pad a list to match the length of template'
nodeid = 'org.sysess.sympathy.list.padlist'
inputs = Ports(
[Port.Custom('[<a>]', 'List with deciding length', name='template'),
Port.Custom('[<b>]', 'List that will be padded', name='list')])
outputs = Ports(
[Port.Custom('[<b>]', 'Padded List', name='list')])
icon = 'pad_list.svg'
parameters = synode.parameters()
parameters.set_list(
'strategy', label='Pad values', value=[0],
description='Specify strategy to use when padding.',
plist=['Repeat last item', 'Empty item'],
editor=synode.Util.combo_editor().value())
def execute(self, node_context):
template = node_context.input['template']
input_ = node_context.input['list']
output = node_context.output['list']
if len(input_) == len(template) == 0:
# Empty output
return
if node_context.parameters['strategy'].value[0] == 0:
fv = input_[-1]
else:
fv = output.create()
for idx, (inp, templ) in enumerate(six.moves.zip_longest(
input_, template, fillvalue=fv)):
output.append(inp)
@deprecated_node('1.5.0', 'Pad List')
class PadListUpdate(PadList):
tags = Tags(Tag.Hidden.Deprecated, Tag.Generic.List)
nodeid = None
name = None
def update_parameters(self, parameters):
name = parameters['strategy'].selected
i = 0 if 'Repeat' in name else 1
parameters['strategy'].list = PadList.parameters['strategy'].list
parameters['strategy'].value = [i]
[docs]class PadADAF(PadListUpdate):
name = 'Pad ADAF'
nodeid = 'org.sysess.sympathy.list.padadaf'
[docs]class PadTable(PadListUpdate):
name = 'Pad Table'
nodeid = 'org.sysess.sympathy.list.padtable'
[docs]class PadADAFUsingTable(PadListUpdate):
name = 'Pad ADAF using Tables'
nodeid = 'org.sysess.sympathy.list.padadafusingtable'
[docs]class PadTableUsingADAF(PadListUpdate):
name = 'Pad Table Using ADAFs'
nodeid = 'org.sysess.sympathy.list.padtableusingadaf'
[docs]class PadListItem(SuperNodeGeneric):
"""Pad a list with item to match another list."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Pad List with Item'
description = 'Pad a list with item match the length of template'
nodeid = 'org.sysess.sympathy.list.padlistitem'
inputs = Ports(
[Port.Custom('[<a>]', 'List with deciding length', name='template'),
Port.Custom('<b>', 'Item to be used as padding', name='item'),
Port.Custom('[<b>]', 'List that will be padded', name='list')])
outputs = Ports(
[Port.Custom('[<b>]', 'The padded List', name='list')])
icon = 'pad_list.svg'
def execute(self, node_context):
template = node_context.input['template']
item = node_context.input['item']
input_ = node_context.input['list']
output = node_context.output['list']
for idx, (inp, templ) in enumerate(six.moves.zip_longest(
input_, template, fillvalue=item)):
output.append(inp)
[docs]@deprecated_node('1.5.3', 'Propagate First Input')
class Propagate(SuperNodeGeneric):
"""
Propagate input to output.
This node is mostly useful for testing purposes.
"""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Propagate Input'
description = 'Propagate input to output'
nodeid = 'org.sysess.sympathy.generic.propagate'
icon = 'propagate.svg'
inputs = Ports([
Port.Custom('<a>', 'Input Item', name='item')])
outputs = Ports(
[Port.Custom('<a>', 'The input Item', name='item')])
def execute(self, node_context):
node_context.output['item'].source(
node_context.input['item'], shallow=True)
[docs]class PropagateFirst(SuperNodeGeneric):
"""
Propagate first input to output.
This node is mostly useful for testing purposes.
It can also be used to force a specific execution
order.
"""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Propagate First Input'
description = 'Propagate first input to output'
nodeid = 'org.sysess.sympathy.generic.propagatefirst'
icon = 'propagate_first.svg'
inputs = Ports([
Port.Custom('<a>', 'The Item to be propagated', name='item1'),
Port.Custom('<b>', 'Item that will not be propagated', name='item2',
n=(0, None, 1))])
outputs = Ports(
[Port.Custom('<a>', 'Propagated Item', name='item')])
def execute(self, node_context):
node_context.output['item'].source(
node_context.input['item1'], shallow=True)
[docs]class PropagateFirstSame(SuperNodeGeneric):
"""
Propagate first input to output.
This node is mostly useful for testing purposes.
It can also be used to force a specific execution
order and to enforce a specific type.
"""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Propagate First Input (Same Type)'
description = 'Propagate first input to output'
nodeid = 'org.sysess.sympathy.generic.propagatefirstsame'
icon = 'propagate_first.svg'
inputs = Ports([
Port.Custom('<a>', 'The Item to be propagated', name='item1'),
Port.Custom('<a>', 'Item that will not be propagated', name='item2')])
outputs = Ports(
[Port.Custom('<a>', 'Propagated Item', name='item')])
def execute(self, node_context):
node_context.output['item'].source(
node_context.input['item1'], shallow=True)
[docs]class ExtendList(SuperNodeGeneric):
"""Extend a list with another list."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Extend List'
description = 'Extend a list'
nodeid = 'org.sysess.sympathy.list.extendlist'
copyright = '(C) 2017 System Engineering Software Society'
icon = 'extend_list.svg'
inputs = Ports([
Port.Custom('[<a>]', 'List that will be added', name='input',
n=(2,)),
])
outputs = Ports(
[Port.Custom('[<a>]', 'The extended List', name='output')])
def execute(self, node_context):
output_list = node_context.output[0]
for input_list in node_context.input.group('input'):
output_list.extend(input_list)
[docs]@deprecated_node('1.5.0', 'Extend List')
class ExtendADAF(ExtendList):
name = 'Extend ADAF'
nodeid = 'org.sysess.sympathy.list.extendadaf'
[docs]@deprecated_node('1.5.0', 'Extend List')
class ExtendText(ExtendList):
name = 'Extend Text'
nodeid = 'org.sysess.sympathy.list.extendtext'
[docs]@deprecated_node('1.5.0', 'Extend List')
class ExtendTable(ExtendList):
name = 'Extend Table'
nodeid = 'org.sysess.sympathy.list.extendtable'
[docs]class FlattenList(SuperNodeGeneric):
"""Flatten a nested list."""
author = 'Magnus Sandén <magnus.sanden@combine.se>'
name = 'Flatten List'
description = 'Flatten a nested list'
nodeid = 'org.sysess.sympathy.list.flattenlist'
icon = 'flatten_list.svg'
inputs = Ports([
Port.Custom('[[<a>]]', 'Nested List', name='in')])
outputs = Ports(
[Port.Custom('[<a>]', 'Flattened List', name='out')])
def execute(self, node_context):
input_list = node_context.input['in']
output_list = node_context.output['out']
for inner_list in input_list:
output_list.extend(inner_list)
[docs]class BisectList(SuperNodeGeneric):
"""
Split a list into two (or optionally more) parts.
To get more than two parts, add more "Extra part" ports.
"""
author = 'Magnus Sandén <magnus.sanden@combine.se>'
name = 'Bisect List'
description = 'Split a list into two (or optionally more) parts'
nodeid = 'org.sysess.sympathy.list.bisectlist'
icon = 'bisect_list.svg'
inputs = Ports([
Port.Custom('[<a>]', 'Full List', name='in')])
outputs = Ports([
Port.Custom('[<a>]', 'Part List', name='part', n=(2, None, 2))])
def execute(self, node_context):
input_list = node_context.input['in']
part_output_lists = node_context.output.group('part')
# When there are an odd number of elements, put one more in the first
# output lists:
n_inputs = len(input_list)
n_groups = len(part_output_lists)
n_min = n_inputs // n_groups
n_ext = n_inputs % n_groups
iinput_list = iter(input_list)
for part_output_list in part_output_lists:
n = n_min
if n_ext > 0:
n_ext -= 1
n += 1
part_output_list.extend(itertools.islice(iinput_list, n))
[docs]@deprecated_node('1.5.3', 'Item to List')
class Repeat(SuperNodeGeneric):
"""Repeat item creating list of item."""
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
name = 'Repeat Item to List'
description = 'Repeat item n times creating list of items'
nodeid = 'org.sysess.sympathy.list.repeatlistitem'
icon = 'repeat_item_to_list.svg'
parameters = synode.parameters()
parameters.set_integer(
'n', label='Number of times', value=0,
description='Choose number of times to repeat item.')
inputs = Ports([
Port.Custom('<a>', 'Input Item', name='item')])
outputs = Ports(
[Port.Custom('[<a>]', 'List containing repeated Items', name='list')])
def execute(self, node_context):
item = node_context.input['item']
output_list = node_context.output['list']
for _ in range(node_context.parameters['n'].value):
output_list.append(item)
[docs]@deprecated_node('1.5.0', 'Pad List')
class MatchTablesList(synode.Node):
"""Match a list of Tables lengths."""
name = "Match Tables list lengths (deprecated)"
nodeid = "org.sysess.sympathy.list.matchtableslist"
description = "Match a list length using guide list."
icon = "match_list.svg"
author = "Erik der Hagopian <erik.hagopian@sysess.org>"
copyright = "(C) 2013 System Engineering Software Society"
version = '1.0'
inputs = Ports([Port.Tables('Guide list', name='guide'),
Port.Tables('Input list', name='input')])
outputs = Ports([Port.Tables('Output list', name='output')])
parameters = synode.parameters()
parameters.set_list(
'fill', value=[0], label='Extend values',
desciption=(
'Specify the values to use if the input has to be extended.'),
plist=['Empty element', 'Last value'],
editor=synode.Util.combo_editor().value())
def execute(self, node_context):
match_length(node_context, table.File())
[docs]@deprecated_node('1.5.0', 'Pad List')
class MatchADAFsList(synode.Node):
"""Match a list of ADAFs lengths."""
name = "Match ADAFs list lengths (deprecated)"
nodeid = "org.sysess.sympathy.list.matchadafslist"
description = "Match a list length using guide list."
icon = "match_list.svg"
author = "Erik der Hagopian <erik.hagopian@sysess.org>"
copyright = "(C) 2013 System Engineering Software Society"
version = '1.0'
inputs = Ports([Port.ADAFs('Guide list', name='guide'),
Port.ADAFs('Input list', name='input')])
outputs = Ports([Port.ADAFs('Output list', name='output')])
parameters = synode.parameters()
parameters.set_list(
'fill', value=[0], label='Extend values',
desciption=(
'Specify the values to use if the input has to be extended.'),
plist=['Empty element', 'Last value'],
editor=synode.Util.combo_editor().value())
def execute(self, node_context):
match_length(node_context, adaf.File())
[docs]class SortList(synode.Node):
"""
Sort List of items using a Python key function that determines order.
For details about how to write the key function see: `Key functions
<https://docs.python.org/2/howto/sorting.html#key-functions>`_. Have a look
at the :ref:`Data type APIs<datatypeapis>` to see what methods and
attributes are available on the data type that you are working with.
Example with port type == [adaf] and item type == adaf:
Sorting input produced by Random ADAFs:
lambda item: item.meta['meta_col0'].value()
"""
name = 'Sort List'
description = 'Sort List using a key function.'
author = 'Erik der Hagopian <erik.hagopian@sysess.org>'
copyright = '(C) 2015 System Engineering Software Society'
nodeid = 'org.sysess.sympathy.list.sortlist'
icon = 'sort_list.svg'
version = '1.0'
tags = Tags(Tag.Generic.List, Tag.DataProcessing.List)
parameters = synode.parameters()
parameters.set_string(
'sort_function',
description='Python key function that determines order.',
value='lambda item: item # Arbitrary key example.',
editor=synode.Util.code_editor().value())
parameters.set_boolean(
'reverse',
label='Reverse order',
description='Use descending (reverse) order.',
value=False)
inputs = Ports([
Port.Custom('[<a>]', 'List to be sorted', name='list')])
outputs = Ports([
Port.Custom('[<a>]', 'Sorted List', name='list')])
def exec_parameter_view(self, node_context):
return sort_util.SortWidget(node_context.input['list'],
node_context)
def execute(self, node_context):
output_list = node_context.output['list']
for item in sort_util.sorted_list(
node_context.parameters['sort_function'].value,
node_context.input['list'],
reverse=node_context.parameters['reverse'].value):
output_list.append(item)
[docs]class SetItemList(SuperNodeGeneric):
"""
Create a list with the items from list (input) but with item inserted at
selected index.
"""
name = 'Insert List'
description = 'Insert item in list'
copyright = '(C) 2017 System Engineering Software Society'
nodeid = 'org.sysess.sympathy.list.insertlist'
icon = 'append_list_new.svg'
tags = Tags(Tag.Generic.List, Tag.DataProcessing.List)
parameters = synode.parameters()
parameters.set_integer('index', label='Index', value=0)
inputs = Ports([
Port.Custom('[<a>]', 'Inserted List', name='list'),
Port.Custom('<a>', 'The Item to be inserted', name='item')])
outputs = Ports([
Port.Custom('[<a>]', 'Inserted List', name='list')])
def execute(self, node_context):
result = node_context.output['list']
input_list = node_context.input['list']
test = list(range(len(input_list)))
test.insert(node_context.parameters['index'].value, -1)
iinput_list = iter(input_list)
for i in test:
if i == -1:
result.append(node_context.input['item'])
result.extend(iinput_list)
break
else:
result.append(next(iinput_list))
[docs]class ChunkList(SuperNodeGeneric):
"""
Split a list into several chunks of at most the specified length.
"""
name = 'Chunk List'
description = ('Split a list into several chunks of at most the specified '
'length')
copyright = '(C) 2017 System Engineering Software Society'
nodeid = 'org.sysess.sympathy.list.chunklist'
icon = 'bisect_list.svg'
tags = Tags(Tag.Generic.List, Tag.DataProcessing.List)
parameters = synode.parameters()
parameters.set_integer('length', label='Length of each chunk', value=0)
inputs = Ports([
Port.Custom('[<a>]', 'List', name='list')])
outputs = Ports([
Port.Custom('[[<a>]]', 'Chunk List', name='chunks')])
def execute(self, node_context):
input_list = node_context.input['list']
chunk_list = node_context.output['chunks']
length = node_context.parameters['length'].value
if length <= 0:
length = len(input_list)
iinput_list = iter(input_list)
items = list(itertools.islice(iinput_list, length))
while items:
chunk = chunk_list.create()
for item in items:
chunk.append(item)
chunk_list.append(chunk)
items = list(itertools.islice(iinput_list, length))