lib/openwfe/expressions/fe_cron.rb in openwferu-0.9.15 vs lib/openwfe/expressions/fe_cron.rb in openwferu-0.9.16

@@ -82,11 +82,11 @@
         def apply (workitem)
 
             @counter = 0
 
             if @children.size < 1
-                reply_to_parent(workitem)
+                reply_to_parent workitem
                 return
             end
 
             @applied_workitem = workitem.dup
             @applied_workitem.flow_expression_id = nil
@@ -102,37 +102,34 @@
 
             clean_children()
 
             @children = nil
 
+            determine_scheduler_tags
+
             #
             # schedule self
             
             reschedule(get_scheduler)
 
             #
             # store self as a variable
             # (have to do it after the reschedule, so that the schedule
             # info is stored within the variable)
 
-            set_variable(@name, self)
+            set_variable @name, self
 
             #
             # resume flow
             
-            reply_to_parent(workitem)
+            reply_to_parent workitem
         end
 
         def reply (workitem)
             # discard silently... should never get called though
         end
 
-        #def cancel ()
-        #end
-            #
-            # implemented in parent TimeExpression class
-
         #
         # This is the method called each time the scheduler triggers
         # this cron. The contained segment of process will get 
         # executed.
         #
@@ -177,20 +174,26 @@
                 unless OpenWFE::starts_with(@name, "//")
 
             if @tab
                 get_scheduler.schedule(
                     @tab, 
-                    { :schedulable => self, :job_id => @scheduler_job_id })
+                    { 
+                        :schedulable => self, 
+                        :job_id => @scheduler_job_id,
+                        :tags => @scheduler_tags })
             else
                 get_scheduler.schedule_every(
                     @every, 
-                    { :schedulable => self, :job_id => @scheduler_job_id })
+                    { 
+                        :schedulable => self, 
+                        :job_id => @scheduler_job_id,
+                        :tags => @scheduler_tags })
             end
 
             ldebug { "reschedule() name is   '#{@name}'" }
             ldebug { "reschedule() job id is '#{@scheduler_job_id}'" }
 
-            #store_itself()
+            #store_itself
                 #
                 # done by the containing environment itself
         end
     end