import logging import knime.extension as knext LOGGER = logging.getLogger(__name__) @knext.node(name="My_Flow_Extension", node_type=knext.NodeType.SINK, icon_path="icon.png",category="/") @knext.input_port(name="Input", description="Data In") @knext.output_port(name="Output", description="Data Out") class My_Flow_Extension: """ Short Descripton. Here is the magic, where is the magic ? """ def configure(self, config_context): return None def execute(self, exec_context): flow_vars = exec_context.flow_variables my_var = flow_vars.get("my_variable", "DefaultValue") print(f"Received Flow Variable: {my_var}") return flow_vars