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}'"