lib/rodimus/step.rb in rodimus-0.1.1 vs lib/rodimus/step.rb in rodimus-0.1.2

@@ -30,21 +30,24 @@
       row.to_s
     end
 
     def run
       Rodimus.logger.info "Running #{self}"
+      @row_count = 1
       incoming.each do |row|
         transformed_row = process_row(row)
         handle_output(transformed_row)
+        Rodimus.logger.info(self) { "#{@row_count} rows processed" } if @row_count % 50000 == 0
+        @row_count += 1
       end
       finalize
       Rodimus.logger.info "Finished #{self}"
     ensure
       close_descriptors
     end
 
     def to_s
-      "#{self.class} connected to input: #{incoming} and output: #{outgoing}"
+      "#{self.class} connected to input: #{incoming || 'nil'} and output: #{outgoing || 'nil'}"
     end
   end
 
 end