Examples of WorkflowInstanceDoesNotExistsException

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1514
1515
1516
1517
1518
1519
1520
1521
1522
1523
      throws RegistryException {
        if (provenanceRegistry != null){
            return provenanceRegistry.getWorkflowInstanceStatus(instanceId);
        }
        if (!isWorkflowInstanceExists(instanceId, true)){
      throw new WorkflowInstanceDoesNotExistsException(instanceId);
    }
    WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(instanceId);
    return new WorkflowExecutionStatus(new WorkflowExecution(wi.getExperimentID(),wi.getWorkflowInstanceID()),wi.getStatus()==null?null:State.valueOf(wi.getStatus()),wi.getLastUpdatedTime());
  }
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1796
1797
1798
1799
1800
1801
1802
1803
1804
1805
      throws RegistryException {
        if (provenanceRegistry != null){
            return provenanceRegistry.getWorkflowStartTime(workflowInstance);
        }
        if (!isWorkflowInstanceExists(workflowInstance.getWorkflowExecutionId(),true)){
      throw new WorkflowInstanceDoesNotExistsException(workflowInstance.getWorkflowExecutionId());
    }
    WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(workflowInstance.getWorkflowExecutionId());
    return wi.getStartTime();
  }
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1832
1833
1834
1835
1836
1837
1838
1839
1840
1841
1842
      String workflowInstanceId) throws RegistryException {
        if (provenanceRegistry != null){
            return provenanceRegistry.getWorkflowInstanceData(workflowInstanceId);
        }
        if (!isWorkflowInstanceExists(workflowInstanceId,true)){
      throw new WorkflowInstanceDoesNotExistsException(workflowInstanceId);
    }
    try{
            WorkflowDataResource resource = jpa.getWorker().getWorkflowInstance(workflowInstanceId);
            WorkflowExecution workflowInstance = new WorkflowExecution(resource.getExperimentID(), resource.getWorkflowInstanceID());
            workflowInstance.setTemplateName(resource.getTemplateName());
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1887
1888
1889
1890
1891
1892
1893
1894
1895
1896
1897
      String nodeId, boolean createIfNotPresent) throws RegistryException {
        if (provenanceRegistry != null){
            return provenanceRegistry.isWorkflowInstanceNodePresent(workflowInstanceId, nodeId, createIfNotPresent);
        }
    if (!isWorkflowInstanceExists(workflowInstanceId, true)){
      throw new WorkflowInstanceDoesNotExistsException(workflowInstanceId);
    }
    if (jpa.getWorker().getWorkflowInstance(workflowInstanceId).isNodeExists(nodeId)){
      return true;
    }else if (createIfNotPresent){
      addWorkflowInstanceNode(workflowInstanceId, nodeId);
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

2391
2392
2393
2394
2395
2396
2397
2398
2399
2400
2401
        throw new ExperimentDoesNotExistsException(experimentId);
      }
      gFacJobs = jpa.getWorker().getExperiment(experimentId).getData().getGFacJobs();
    }else if (nodeId==null){
      if (!isWorkflowInstanceExists(workflowExecutionId)){
        throw new WorkflowInstanceDoesNotExistsException(workflowExecutionId);
      }
      gFacJobs = jpa.getWorker().getExperiment(experimentId).getData().getWorkflowInstance(workflowExecutionId).getGFacJobs();
    }else{
      if (!isWorkflowInstanceNodePresent(workflowExecutionId, nodeId)){
        throw new WorkflowInstanceNodeDoesNotExistsException(workflowExecutionId, nodeId);
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1431
1432
1433
1434
1435
1436
1437
1438
1439
1440
  public String getWorkflowExecutionTemplateName(String workflowInstanceId) throws RegistryException {
        if (provenanceRegistry != null){
            return provenanceRegistry.getWorkflowExecutionTemplateName(workflowInstanceId);
        }
    if (!isWorkflowInstanceExists(workflowInstanceId, true)){
      throw new WorkflowInstanceDoesNotExistsException(workflowInstanceId);
    }
    WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(workflowInstanceId);
    return wi.getTemplateName();
  }
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1445
1446
1447
1448
1449
1450
1451
1452
1453
1454
1455
      String templateName) throws RegistryException {
        if (provenanceRegistry != null){
            provenanceRegistry.setWorkflowInstanceTemplateName(workflowInstanceId, templateName);
        }else {
            if (!isWorkflowInstanceExists(workflowInstanceId, true)){
                throw new WorkflowInstanceDoesNotExistsException(workflowInstanceId);
            }
            WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(workflowInstanceId);
            wi.setTemplateName(templateName);
            wi.save();
        }
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1513
1514
1515
1516
1517
1518
1519
1520
1521
1522
1523
      State status) throws RegistryException {
        if (provenanceRegistry != null){
            provenanceRegistry.updateWorkflowInstanceStatus(instanceId, status);
        }else {
            if (!isWorkflowInstanceExists(instanceId, true)){
                throw new WorkflowInstanceDoesNotExistsException(instanceId);
            }
            WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(instanceId);
            Timestamp currentTime = new Timestamp(Calendar.getInstance().getTime().getTime());
            wi.setStatus(status.toString());
            if (status==State.STARTED){
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1534
1535
1536
1537
1538
1539
1540
1541
1542
1543
1544
      throws RegistryException {
        if (provenanceRegistry != null){
            provenanceRegistry.updateWorkflowInstanceStatus(status);
        }else {
            if (!isWorkflowInstanceExists(status.getWorkflowInstance().getWorkflowExecutionId(), true)){
                throw new WorkflowInstanceDoesNotExistsException(status.getWorkflowInstance().getWorkflowExecutionId());
            }
            WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(status.getWorkflowInstance().getWorkflowExecutionId());
            Timestamp currentTime = new Timestamp(status.getStatusUpdateTime().getTime());
            if(status.getExecutionStatus() != null){
                wi.setStatus(status.getExecutionStatus().toString());
View Full Code Here

Examples of org.apache.airavata.registry.api.exception.worker.WorkflowInstanceDoesNotExistsException

1558
1559
1560
1561
1562
1563
1564
1565
1566
1567
      throws RegistryException {
        if (provenanceRegistry != null){
            return provenanceRegistry.getWorkflowInstanceStatus(instanceId);
        }
        if (!isWorkflowInstanceExists(instanceId, true)){
      throw new WorkflowInstanceDoesNotExistsException(instanceId);
    }
    WorkflowDataResource wi = jpa.getWorker().getWorkflowInstance(instanceId);
    return new WorkflowExecutionStatus(new WorkflowExecution(wi.getExperimentID(),wi.getWorkflowInstanceID()),wi.getStatus()==null?null:State.valueOf(wi.getStatus()),wi.getLastUpdatedTime());
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.