How to query all tasks of a given workflow instance? (NPE)

nicolasraoul — Mon, 22 Feb 2010 10:20:27 GMT

I want to get the list of tasks of a given workflow instance. So I wrote:WorkflowTaskQuery query = new WorkflowTaskQuery();query.setProcessId("jbpm$" + new Long(processInstance.getId()).toString());query.setTaskState(WorkflowTaskState.COMPLETED); // TODO add those IN_PROGRESSList<WorkflowTask>

Re: How to query all tasks of a given workflow instance? (NPE)

nicolasraoul — Tue, 02 Mar 2010 05:50:20 GMT

Context: the last step of a workflow reads the workflow's tasks history.

This exception appears because I am running the query within a jBPM ActionHandler. If I am running the query from non-jBPM-related classes (for instance a custom dialog) then it works. But I need to run the query as the last step of the workflow, so the last action handler is the only place where I can do it.

Querying the workflow from the Java code in the workflow' action handler itself confuses jBPM to the point of generating a NullPointerException.
I guess it is a bug in jBPM.

Here is an unreliable workaround (it works most of the time but race conditions might make it fail, so it is not a reliable solution):

- In MyActionHandler, launch a worker thread that you can call WorkflowQueryWorker.
- In WorkflowQueryWorker, do the query.

It works, probably because the worker thread is not part of any jBPM transaction.
But there is a race between the two threads. If for some reason the main thread goes faster, then the workflow may finish and the workflow's history be removed, which means the query will return no results.

Code in the ActionHandler:

PublishWorker worker = new PublishWorker(processInstance.getId(), nodeRefs, workflowService, nodeService);
ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(5);
ThreadPoolExecutor threadExecutor = new ThreadPoolExecutor(10, 20, 60, TimeUnit.SECONDS, queue);
threadExecutor.execute(worker);‍‍‍‍

Code in the worker:

public class PublishWorker implements Runnable {

   private QName PROP_QNAME_HISTORY = QName.createQName("http://www.my.org/", "approvalHistory");
   
   private long processId;
   
   private List<NodeRef> nodeRefs;
   
   private WorkflowService workflowService;
   
   private NodeService nodeService;
   
   public PublishWorker(long processId, List<NodeRef> nodeRefs, WorkflowService workflowService, NodeService nodeService) {
      this.processId = processId;
      this.nodeRefs = nodeRefs;
      this.workflowService = workflowService;
      this.nodeService = nodeService;
   }
   
   @Override
   public void run() {
      System.out.println("PublishWorker.run enter");
      
      // Read history from workflow.
      // Needs to be done fast, because the workflow is finishing in another thread,
      // and history is deleted when the workflow finishes. 
      String history = readHistory();
      System.out.println("history:" + history);

      // Wait for the nodes to be written in the main thread, otherwise we get a InvalidNodeRefException
      try {
         Thread.sleep(5000);
      } catch (InterruptedException e) {}
      
      final String finalHistory = history;
      for(NodeRef nodeRef : nodeRefs) {
         // Write workflow history to the published document, as admin.
         final NodeRef finalNodeRef = nodeRef;
         RunAsWork<Object> work = new RunAsWork<Object>() {
              public Object doWork() throws Exception {
                 // Set the history property.
                 nodeService.setProperty(finalNodeRef, PROP_QNAME_HISTORY, finalHistory);
                 return new Object(); // Have to return something.
              }
         };
         AuthenticationUtil.runAs(work, "admin");
      }
      System.out.println("PublishWorker.run exit");
   }
   
   /**
    * Read history of a workflow instance.
    * @return history as a human-readable String.
    */
   private String readHistory() {
      
      // Build processId string.
        String processIdString = "jbpm$" + new Long(processId).toString();

      // Get completed tasks for current workflow instance.
      WorkflowTaskQuery query = new WorkflowTaskQuery();
        //query.setActive(workflowInstance.active);
        query.setProcessId(processIdString);
        query.setTaskState(WorkflowTaskState.COMPLETED);
        query.setOrderBy(new WorkflowTaskQuery.OrderBy[] {
                 WorkflowTaskQuery.OrderBy.TaskCreated_Desc,
                 WorkflowTaskQuery.OrderBy.TaskActor_Asc });
        List<WorkflowTask> completedTasks = workflowService.queryTasks(query);

      // Get in-progress tasks for current workflow instance.
        query.setTaskState(WorkflowTaskState.IN_PROGRESS);
        List<WorkflowTask> inProgressTasks = workflowService.queryTasks(query);
        
        // Join tasks.
        List<WorkflowTask> tasks = new ArrayList<WorkflowTask>();
        tasks.addAll(completedTasks);
        tasks.addAll(inProgressTasks);
        
        // Print the tasks to a String.
        StringBuffer historyBuffer = new StringBuffer();
        for (WorkflowTask task : tasks)
        {
           // Get task characteristics.
           Long id = (Long)task.properties.get(WorkflowModel.PROP_TASK_ID);
           String desc = (String)task.properties.get(WorkflowModel.PROP_DESCRIPTION);
           Date createdDate = (Date)task.properties.get(ContentModel.PROP_CREATED);
           String owner = (String)task.properties.get(ContentModel.PROP_OWNER);
           String comment = (String)task.properties.get(WorkflowModel.PROP_COMMENT);
           Date completedDate = (Date)task.properties.get(WorkflowModel.PROP_COMPLETION_DATE);
           String transition = (String)task.properties.get(WorkflowModel.PROP_OUTCOME);
           String outcome = "";
           if (transition != null)
           {
              WorkflowTransition[] transitions = task.definition.node.transitions;
              for (WorkflowTransition trans : transitions)
              {
                 if (trans.id.equals(transition))
                 {
                    outcome = trans.title;
                    break;
                 }
              }
           }
           // Write task characteristics.
           historyBuffer.append(id.toString());
           historyBuffer.append(" ; ");
           historyBuffer.append(desc == null ? "" : Utils.encode(desc));
           historyBuffer.append(" ; ");
           historyBuffer.append(Utils.encode(task.title));
           historyBuffer.append(" ; ");
           historyBuffer.append(createdDate);
           historyBuffer.append(" ; ");
           historyBuffer.append(owner == null ? "" : owner);
           historyBuffer.append(" ; ");
           historyBuffer.append(comment == null ? "" : Utils.encode(comment));
           historyBuffer.append(" ; ");
           historyBuffer.append(completedDate);
           historyBuffer.append(" ; ");
           historyBuffer.append(outcome);
           historyBuffer.append("\n");
        }
        return historyBuffer.toString();
   }   
}‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

Can you suggest any improvement?
In particular, how to make it more reliable and remove the race condition?
Or a better workaround for this bug?

Thanks a lot,
Nicolas Raoul

Re: How to query all tasks of a given workflow instance? (NPE)

talija83 — Thu, 22 Apr 2010 20:14:45 GMT

Has anybody found a solution for this problem? :cry:

Re: How to query all tasks of a given workflow instance? (NPE)

nicolasraoul — Fri, 23 Apr 2010 01:09:04 GMT

I asked my Alfresco Enterprise support, and they created a JIRA issue:
https://issues.alfresco.com/jira/browse/ALF-2337
But no progress since.
So the system I created will be deployed in production next week, with the silly workaround I described above :shock:

topic Re: How to query all tasks of a given workflow instance? (NPE) in Alfresco Archive

How to query all tasks of a given workflow instance? (NPE)

Re: How to query all tasks of a given workflow instance? (NPE)

Re: How to query all tasks of a given workflow instance? (NPE)

Re: How to query all tasks of a given workflow instance? (NPE)