Hi Chandrika,
I would use ComputeTaskSession and ComputeTaskSessionAttributeListener to
achieve that:
- Inject ComputeTaskSession to your task and/or jobs like
this: @TaskSessionResource private ComputeTaskSession taskSes;
You also need to annotate your task with @ComputeTaskSessionFullSupport
- In your jobs add a custom attribute
listener:
taskSes.addAttributeListener(yourListenerImplementingComputeTaskSessionAttributeListener,
false);
- Then add attributes for the events you are interested
in: taskSes.setAttribute("jobStatus", "started");
- You might also use ComputeTaskSession#waitForAttribute()
--
Best regards,
Alexey
