lib/tasks/beso.rake in beso-0.1.0 vs lib/tasks/beso.rake in beso-0.2.0

@@ -17,10 +17,19 @@
       puts '==> Config:'
       puts config.inspect
 
       Beso.jobs.each do |job|
 
-        config[ job.event ] ||= job.first_timestamp
+        config[ job.event ] ||= begin
+          case ENV[ 'BESO_ORIGIN' ]
+          when 'first'
+            job.first_timestamp
+          when 'now'
+            Time.now
+          else
+            job.last_timestamp
+          end
+        end
 
         puts "==> Processing job: #{job.event.inspect} since #{config[ job.event ]}"
 
         csv = job.to_csv :since => config[ job.event ]