lib/rodimus/step.rb in rodimus-0.0.1 vs lib/rodimus/step.rb in rodimus-0.1.0

@@ -2,14 +2,20 @@
 
   module Step
     attr_accessor :incoming, :outgoing
 
     def run
+      Rodimus.logger.info "Running #{self}"
       incoming.each do |row|
         transformed_row = process_row(row)
         handle_output(transformed_row)
       end
       finalize
+      Rodimus.logger.info "Finished #{self}"
+    end
+
+    def to_s
+      "#{self.class} connected to input: #{incoming} and output: #{outgoing}"
     end
 
     private
 
     # Override this for custom functionality