Hi Devs,

I have started a workflow and waited on following statement

TaskState taskState =
taskDriver.pollForWorkflowState(workflow.getName(),
TaskState.COMPLETED, TaskState.FAILED, TaskState.STOPPED,
TaskState.ABORTED);

Here, a task state was received once all the jobs are completed. However if
one task of the workflow was failed, I got following error after the
timeout.

What could be the reason for that?

org.apache.helix.HelixException: Workflow "Airavata_Process_95" context is
empty or not in states: "[Lorg.apache.helix.task.TaskState;@97d2fbf"
at
org.apache.helix.task.TaskDriver.pollForWorkflowState(TaskDriver.java:894)
~[helix-core-0.6.7.jar:0.6.7]
at
org.apache.helix.task.TaskDriver.pollForWorkflowState(TaskDriver.java:914)
~[helix-core-0.6.7.jar:0.6.7]
at
org.apache.airavata.k8s.gfac.core.HelixWorkflowManager.launchWorkflow(HelixWorkflowManager.java:79)
~[classes/:na]
at
org.apache.airavata.k8s.gfac.service.WorkerService$2.run(WorkerService.java:91)
[classes/:na]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[na:1.8.0_144]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[na:1.8.0_144]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_144]

Thanks
Dimuthu

Reply via email to