fe_participant.rb in openwferu-0.9.5

- old
+ new

@@ -67,10 +67,12 @@
         #
         # apply / reply
 
         def apply (workitem)
 
+            remove_timedout_flag(workitem)
+
             @applied_workitem = workitem.dup
 
             @participant_name = OpenWFE::lookup_ref(self, workitem)
 
             @participant_name = OpenWFE::fetch_text_content(self, workitem) \
@@ -120,9 +122,12 @@
                 @scheduler_job_id = nil
                     #
                     # so that cancel won't unschedule without need 
 
                 cancel()
+
+                set_timedout_flag(@applied_workitem)
+
                 reply_to_parent(@applied_workitem)
             rescue
                 lerror do
                     "trigger() problem while timing out\n"+
                     OpenWFE::exception_to_s($!)