lib/rsched/engine.rb in rsched-0.3.1 vs lib/rsched/engine.rb in rsched-0.3.2

@@ -54,10 +54,11 @@
     @extend_timeout = conf[:extend_timeout]
     @kill_timeout = conf[:kill_timeout]
     @kill_retry = conf[:kill_retry]
     @sched_start = conf[:from] || 0
     @release_on_fail = conf[:release_on_fail]
+    @env = conf[:env] || {}
     @finished = false
     @ss = {}
 
     @extender = TimerThread.new(@lock, @extend_timeout, @kill_timeout, @kill_retry)
 
@@ -143,9 +144,13 @@
     end
   end
 
   def process(token, ident, time, action)
     puts "started token=#{token.inspect} time=#{time}"
+
+    @env.each_pair {|k,v|
+      ENV[k] = v
+    }
 
     @extender.set_token(token)
 
     success = false
     begin