lib/openwfe/expressions/fe_participant.rb in openwferu-0.9.3 vs lib/openwfe/expressions/fe_participant.rb in openwferu-0.9.4
- old
+ new
@@ -75,10 +75,11 @@
@participant_name = OpenWFE::fetch_text_content(self, workitem) \
unless @participant_name
determine_timeout()
+ reschedule(get_scheduler)
store_itself()
get_participant_map.dispatch(@participant_name, workitem)
end
@@ -92,13 +93,9 @@
# to notify it of the cancellation.
#
def cancel
wi = super()
-
- if @scheduler_job_id
- get_scheduler.unschedule(@scheduler_job_id)
- end
return wi unless @applied_workitem
#
# have to cancel the workitem on the participant side