lib/rflow/component.rb in rflow-1.0.1 vs lib/rflow/component.rb in rflow-1.1.0

- old
+ new

@@ -89,14 +89,14 @@ def shard; worker.shard if worker; end # Returns a list of connected input ports. Each port will have # one or more keys associated with a particular connection. - def input_ports; ports.by_type["RFlow::Component::InputPort"]; end + def input_ports; ports.by_type['RFlow::Component::InputPort']; end # Returns a list of connected output ports. Each port will have # one or more keys associated with the particular connection. - def output_ports; ports.by_type["RFlow::Component::OutputPort"]; end + def output_ports; ports.by_type['RFlow::Component::OutputPort']; end def configure_input_port!(port_name, options = {}) RFlow.logger.debug "Configuring component '#{name}' (#{uuid}) input port '#{port_name}' (#{options[:uuid]})" unless self.class.defined_input_ports.include? port_name raise ArgumentError, "Input port '#{port_name}' not defined on component '#{self.class}'"