You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2015/02/06 17:05:39 UTC
[26/53] [abbrv] airavata git commit: retiring workflow tracking
schema - AIRAVATA-1557
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/MessageUtil.java
----------------------------------------------------------------------
diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/MessageUtil.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/MessageUtil.java
deleted file mode 100644
index 8e61445..0000000
--- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/MessageUtil.java
+++ /dev/null
@@ -1,562 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.workflow.tracking.util;
-
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ApplicationAudit;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ComputationDuration;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.DataConsumed;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.DataProduced;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.DataReceiveDuration;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.DataSendDuration;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.InvokingService;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.InvokingServiceFailed;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.InvokingServiceSucceeded;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.JobStatus;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.LogDebug;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.LogException;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.LogInfo;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.LogWarning;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.PublishURL;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ReceivedFault;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ReceivedResult;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ResourceMapping;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.SendingFault;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.SendingResponseFailed;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.SendingResponseSucceeded;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.SendingResult;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ServiceInitialized;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ServiceInvoked;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.ServiceTerminated;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.WorkflowInitialized;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.WorkflowInvoked;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.WorkflowPaused;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.WorkflowResumed;
-import static org.apache.airavata.workflow.tracking.client.NotificationType.WorkflowTerminated;
-
-import java.net.URI;
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import javax.xml.namespace.QName;
-
-import org.apache.airavata.commons.LeadContextHeader;
-import org.apache.airavata.workflow.tracking.client.NotificationType;
-import org.apache.airavata.workflow.tracking.common.AnnotationConsts;
-import org.apache.airavata.workflow.tracking.common.AnnotationProps;
-import org.apache.airavata.workflow.tracking.common.ConstructorConsts;
-import org.apache.airavata.workflow.tracking.common.ConstructorProps;
-import org.apache.airavata.workflow.tracking.types.*;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.xmlbeans.XmlAnySimpleType;
-import org.apache.xmlbeans.XmlCalendar;
-import org.apache.xmlbeans.XmlCursor;
-import org.apache.xmlbeans.XmlException;
-import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.XmlOptions;
-
-/**
- * Utility library to extract standard fields from LEAD message
- */
-public class MessageUtil {
-
- public static final String WFT_NS = "http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking";
- public static final QName ANNO_QNAME = new QName(WFT_NS, "annotation");
-
- /**
- * Returns the type of the LEAD Message as a Enum type. This byte ID can be used to quickly check the type of lead
- * message using an if..then statement or a switch statement
- *
- * @param message
- * a LEAD Message Xml Document
- *
- * @return An Enum of type <code> org.apache.airavata.workflow.tracking.util.NOtificationType</code>
- *
- */
- public static final NotificationType getType(XmlObject message) {
-
- if (message instanceof ServiceInitializedDocument)
- return ServiceInitialized;
- if (message instanceof WorkflowInitializedDocument)
- return WorkflowInitialized;
- if (message instanceof ServiceTerminatedDocument)
- return ServiceTerminated;
- if (message instanceof WorkflowTerminatedDocument)
- return WorkflowTerminated;
- if (message instanceof InvokingServiceDocument)
- return InvokingService;
- if (message instanceof WorkflowInvokedDocument)
- return WorkflowInvoked;
- if (message instanceof ServiceInvokedDocument)
- return ServiceInvoked;
- if (message instanceof WorkflowPausedDocument)
- return WorkflowPaused;
- if (message instanceof WorkflowResumedDocument)
- return WorkflowResumed;
- if (message instanceof InvokingServiceSucceededDocument)
- return InvokingServiceSucceeded;
- if (message instanceof InvokingServiceFailedDocument)
- return InvokingServiceFailed;
- if (message instanceof SendingResultDocument)
- return SendingResult;
- if (message instanceof SendingFaultDocument)
- return SendingFault;
- if (message instanceof ReceivedResultDocument)
- return ReceivedResult;
- if (message instanceof ReceivedFaultDocument)
- return ReceivedFault;
- if (message instanceof SendingResponseSucceededDocument)
- return SendingResponseSucceeded;
- if (message instanceof SendingResponseFailedDocument)
- return SendingResponseFailed;
- if (message instanceof DataConsumedDocument)
- return DataConsumed;
- if (message instanceof DataProducedDocument)
- return DataProduced;
- if (message instanceof ApplicationAuditDocument)
- return ApplicationAudit;
- if (message instanceof ComputationDurationDocument)
- return ComputationDuration;
- if (message instanceof DataSendDurationDocument)
- return DataSendDuration;
- if (message instanceof DataReceiveDurationDocument)
- return DataReceiveDuration;
- if (message instanceof PublishURLDocument)
- return PublishURL;
- if (message instanceof LogInfoDocument)
- return LogInfo;
- if (message instanceof LogExceptionDocument)
- return LogException;
- if (message instanceof LogWarningDocument)
- return LogWarning;
- if (message instanceof LogDebugDocument)
- return LogDebug;
- if (message instanceof ResourceMappingDocument)
- return ResourceMapping;
- if (message instanceof JobStatusDocument)
- return JobStatus;
-
- // default
- return NotificationType.Unknown;
- }
-
- public static ActivityTime getActivityTime(XmlObject activity) throws ParseException {
- Date clockTime = getActivityTimestamp(activity);
- int logicalTime = getActivityWorkflowTimestep(activity);
- return new ActivityTime(logicalTime, clockTime);
- }
-
- public static final QName TIMESTAMP_QNAME = new QName(WFT_NS, "timestamp");
- public static final QName NOTIFICATION_SRC_QNAME = new QName(WFT_NS, "notificationSource");
- public static final QName WF_TIMESTEP_QNAME = new QName(WFT_NS, "workflowTimestep");
-
- public static Date getActivityTimestamp(XmlObject activity) throws ParseException {
- // $ACTIVITY_XML/*/timestamp
- XmlCursor xc = activity.newCursor();
- // ./
- // xc.toStartDoc();
- // ./*
- xc.toNextToken();
- // ./*/timestamp
- xc.toChild(TIMESTAMP_QNAME);
- System.out.println(xc.xmlText());
- XmlCalendar calendar = new XmlCalendar(xc.getTextValue());
- // return getDateFormat().parse(xc.getTextValue()); // fixme: this
- // supports only one date format
- return calendar.getTime();
- }
-
- static SimpleDateFormat getDateFormat() {
- return new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSZ");
- }
-
- public static int getActivityWorkflowTimestep(XmlObject activity) {
- // $ACTIVITY_XML/*/notificationSource/@workflowTimestep
- XmlCursor xc = activity.newCursor();
- // ./
- // xc.toStartDoc();
- // ./*
- xc.toNextToken();
- // ./*/notificationSource
- xc.toChild(NOTIFICATION_SRC_QNAME);
- // ./*/notificationSource/@*
- boolean hasAttr = xc.toFirstAttribute();
- while (hasAttr && !WF_TIMESTEP_QNAME.equals(xc.getName())) {
- hasAttr = xc.toNextAttribute();
- }
- if (hasAttr) {
- // ./*/notificationSource/@workflowTimestep
- return Integer.parseInt(xc.getTextValue());
- } else {
- return -1;
- }
- }
-
- public static List<XmlObject> getAnnotations(XmlObject message, AnnotationConsts annoElementQName) {
- // locate the wft:annotation element
- final String ANNO_XPATH = "declare namespace wft='" + ANNO_QNAME.getNamespaceURI() + "' .//wft:"
- + ANNO_QNAME.getLocalPart();
- XmlObject[] annoObj = message.selectPath(ANNO_XPATH);
- // for(XmlObject obj : annoObj){ System.out.println(obj); }
- // if no result, return nothing
- if (annoObj == null || annoObj.length == 0)
- return new ArrayList<XmlObject>(0);
- // if more than one 'annotation' element, select only first. FIXME?
- // Throw exception?
- final String ANNO_ELEMENT_XPATH = "declare namespace ann='" + annoElementQName.getQName().getNamespaceURI()
- + "' .//ann:" + annoElementQName.getQName().getLocalPart();
- XmlObject[] annoElements = annoObj[0].selectPath(ANNO_ELEMENT_XPATH);
- // for(XmlObject obj : annoElements){ System.out.println(obj); }
- return Arrays.asList(annoElements);
- }
-
- public static List<String> getSimpleAnnotations(XmlObject message, AnnotationConsts annoElementQName)
- throws XmlException {
- List<XmlObject> simpleXmlElements = getAnnotations(message, annoElementQName);
- List<String> simpleElements = new ArrayList<String>(simpleXmlElements.size());
- for (XmlObject obj : simpleXmlElements) {
- simpleElements.add((XmlAnySimpleType.Factory.parse(obj.xmlText())).stringValue());
- }
- return simpleElements;
- }
-
- public static Map<QName, XmlObject> getAllAnnotations(XmlObject message) throws XmlException {
- // locate the wft:annotation element
- final String ANNO_XPATH = "declare namespace wft='" + ANNO_QNAME.getNamespaceURI() + "' .//wft:"
- + ANNO_QNAME.getLocalPart();
- XmlObject[] annoObj = message.selectPath(ANNO_XPATH);
- // for(XmlObject obj : annoObj){ System.out.println(obj); }
- // if no result, return nothing
- if (annoObj == null || annoObj.length == 0)
- return new HashMap<QName, XmlObject>();
- // if more than one 'annotation' element, select only first. FIXME?
- // Throw exception?
- final String ANNO_ELEMENT_XPATH = "*";
- XmlObject[] annoElements = annoObj[0].selectPath(ANNO_ELEMENT_XPATH);
- // for(XmlObject obj : annoElements){ System.out.println(obj); }
- Map<QName, XmlObject> annoMap = new HashMap<QName, XmlObject>();
- for (XmlObject annoFrag : annoElements) {
- XmlObject annoElt = XmlObject.Factory.parse(annoFrag.xmlText(new XmlOptions().setSaveOuter()));
- // System.out.println(annoElt);
- XmlCursor xc = annoElt.newCursor();
- xc.toNextToken();
- // System.out.println(xc.getName());
- // System.out.println(xc.getObject());
- annoMap.put(xc.getName(), xc.getObject());
- }
- return annoMap;
- }
-
- public static Map<QName, String> getSimpleAnnotations(XmlObject message) throws XmlException {
- Map<QName, XmlObject> simpleXmlElements = getAllAnnotations(message);
- Map<QName, String> simpleElements = new HashMap<QName, String>(simpleXmlElements.size());
- for (Map.Entry<QName, XmlObject> obj : simpleXmlElements.entrySet()) {
- simpleElements.put(obj.getKey(), (XmlAnySimpleType.Factory.parse(obj.getValue().xmlText())).stringValue());
- }
- return simpleElements;
- }
-
- /**
- * Constructs a conttructorProps from LeadContextHeader.
- *
- * This methods sets annotations available in LeadContextHeader. You still need to set additional annotations if any
- * before calling NotifierFactory.createNotifier().
- *
- * @param leadContext
- * @return The constructor props created.
- */
- public static ConstructorProps createConstructorPropsFromLeadContext(LeadContextHeader leadContext) {
- EndpointReference sinkEpr = leadContext.getEventSink();
- ConstructorProps props = ConstructorProps.newProps(ConstructorConsts.BROKER_EPR, sinkEpr.getAddress());
-
- AnnotationProps annotationProps = AnnotationProps.newProps();
- String experimentId = leadContext.getExperimentId();
- if (experimentId != null) {
- annotationProps.set(AnnotationConsts.ExperimentID, experimentId);
- }
- URI workflowTemplateId = leadContext.getWorkflowTemplateId();
- if (workflowTemplateId != null) {
- annotationProps.set(AnnotationConsts.AbstractWorkflowID, workflowTemplateId.toString());
- }
- String userDn = leadContext.getUserDn();
- if (userDn != null) {
- annotationProps.set(AnnotationConsts.UserDN, userDn);
- }
- props.set(ConstructorConsts.ANNOTATIONS, annotationProps);
- return props;
- }
-
- public static void testAnno(String[] args) throws XmlException {
- String test1 = "<wor:dataProduced xmlns:wor='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>"
- + "<wor:notificationSource wor:serviceID='urn:qname:http://org.apache.airavata/lead:Terrain' wor:workflowID='tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46' wor:workflowTimestep='6' wor:workflowNodeID='Terrain_Preprocessor'/>"
- + "<wor:timestamp>2007-02-14T15:44:46.509-05:00</wor:timestamp>"
- + "<wor:dataProduct>"
- + "<wor:id>gsiftp://bigred.iu.teragrid.org//N/gpfsbr/tg-drlead/workDirs/Terrain_Wed_Feb_14_15_44_42_EST_2007_b017e36f-146e-4852-89de-e26b00d82d77/inputData/arpstrn.input</wor:id>"
- + "<wor:location>gsiftp://bigred.iu.teragrid.org//N/gpfsbr/tg-drlead/workDirs/Terrain_Wed_Feb_14_15_44_42_EST_2007_b017e36f-146e-4852-89de-e26b00d82d77/inputData/arpstrn.input</wor:location>"
- + "<wor:sizeInBytes>-1</wor:sizeInBytes>"
- + "<wor:timestamp>2007-02-14T15:44:46.508-05:00</wor:timestamp>"
- + "<wor:description>gsiftp://bigred.iu.teragrid.org//N/gpfsbr/tg-drlead/workDirs/Terrain_Wed_Feb_14_15_44_42_EST_2007_b017e36f-146e-4852-89de-e26b00d82d77/inputData/arpstrn.input</wor:description>"
- + "<wor:annotation>"
- + "<dataProductType xmlns='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>LEADNameListFile</dataProductType>"
- + "</wor:annotation>" + "</wor:dataProduct>" + "</wor:dataProduced>";
- String test2 = "<wor:serviceInvoked xmlns:wor='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>"
- + " <wor:notificationSource wor:serviceID='urn:qname:http://org.apache.airavata/lead:Terrain' wor:workflowID='tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46' wor:workflowTimestep='6' wor:workflowNodeID='Terrain_Preprocessor'/>"
- + " <wor:timestamp>2007-02-14T15:44:42.784-05:00</wor:timestamp>"
- + " <wor:description>Service Invoked</wor:description>"
- + " <wor:annotation>"
- + " <typedSOAPRequest xmlns='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>"
- + " <S:Envelope xmlns:wsa='http://www.w3.org/2005/08/addressing' xmlns:wsp='http://schemas.xmlsoap.org/ws/2002/12/policy' xmlns:S='http://schemas.xmlsoap.org/soap/envelope/'>"
- + " <S:Header>"
- + " <lh:context xmlns:lh='http://lead.extreme.indiana.edu/namespaces/2005/10/lead-context-header'>"
- + " <lh:experiment-id>urn:uuid:3f422b0b-912f-49c1-8bb6-0c5612d160bf</lh:experiment-id>"
- + " <lh:event-sink-epr>"
- + " <wsa:Address>http://tyr11.cs.indiana.edu:12346/topic/3f422b0b-912f-49c1-8bb6-0c5612d160bf</wsa:Address>"
- + " </lh:event-sink-epr>"
- + " <lh:user-dn>/O=LEAD Project/OU=portal.leadproject.org/OU=cs.indiana.edu/CN=marcus/EMAIL=machrist@cs.indiana.edu</lh:user-dn>"
- + " <lh:resource-catalog-url>https://everest.extreme.indiana.edu:22443/resource_catalog?wsdl</lh:resource-catalog-url>"
- + " <lh:gfac-url>https://tyr09.cs.indiana.edu:23443?wsdl</lh:gfac-url>"
- + " <lh:mylead-agent-url>https://bitternut.cs.indiana.edu:10243/myleadagent?wsdl</lh:mylead-agent-url>"
- + " <lh:OUTPUT_DATA_DIRECTORY>gsiftp://chinkapin.cs.indiana.edu//data/data-output/3f422b0b-912f-49c1-8bb6-0c5612d160bf</lh:OUTPUT_DATA_DIRECTORY>"
- + " <lh:OPENDAP_DIRECTORY>opendap://chinkapin.cs.indiana.edu:8080/thredds/dodsC/data/data-output/3f422b0b-912f-49c1-8bb6-0c5612d160bf</lh:OPENDAP_DIRECTORY>"
- + " <lh:OUTPUT_DATA_FILES_SUFFIX>.nc</lh:OUTPUT_DATA_FILES_SUFFIX>"
- + " <lh:workflow-instance-id>tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46</lh:workflow-instance-id>"
- + " <lh:resource-broker-url>http://152.54.1.30:3333/resourcebroker?wsdl</lh:resource-broker-url>"
- + " <lh:workflow-time-step>6</lh:workflow-time-step>"
- + " <lh:workflow-node-id>Terrain_Preprocessor</lh:workflow-node-id>"
- + " <lh:service-instance-id>http://tempuri.org/no-service-id</lh:service-instance-id>"
- + " </lh:context>"
- + " <wsa:MessageID>tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46/outgoing/Terrain_PreprocessorPartner/1</wsa:MessageID>"
- + " <wsa:ReplyTo>"
- + " <wsa:Address>http://tyr10.cs.indiana.edu:7080/gpel/728/ADASInitializedWRFForecasting/instance46/incoming/Terrain_PreprocessorPartner.atom</wsa:Address>"
- + " </wsa:ReplyTo>"
- + " <wsa:Action/>"
- + " <wsa:To>https://tyr11.cs.indiana.edu:12554/</wsa:To>"
- + " <wsa:FaultTo>"
- + " <wsa:Address>http://tyr10.cs.indiana.edu:7080/gpel/728/ADASInitializedWRFForecasting/instance46/incoming/Terrain_PreprocessorPartner.atom</wsa:Address>"
- + " </wsa:FaultTo>"
- + " <wsa:RelatesTo>tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46/outgoing/Terrain_PreprocessorPartner/1</wsa:RelatesTo>"
- + " </S:Header>"
- + " <S:Body>"
- + " <terrain_preprocessortypens:Preprocessor_InputParams xmlns:terrain_preprocessortypens='http://org.apache.airavata/lead/Terrain/xsd'>"
- + " <CrossCuttingConfigurations n1:leadType='LeadCrosscutParameters' xmlns:n1='http://org.apache.airavata/namespaces/2004/01/gFac'>"
- + " <lcp:nx xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>53</lcp:nx>"
- + " <lcp:ny xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>53</lcp:ny>"
- + " <lcp:dx xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>20000</lcp:dx>"
- + " <lcp:dy xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>20000</lcp:dy>"
- + " <lcp:fcst_time xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>12.0</lcp:fcst_time>"
- + " <lcp:start_date xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>2007/02/13</lcp:start_date>"
- + " <lcp:start_hour xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>18</lcp:start_hour>"
- + " <lcp:ctrlat xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>39.97712</lcp:ctrlat>"
- + " <lcp:ctrlon xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>-86.484375</lcp:ctrlon>"
- + " <lcp:westbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>-90.97595</lcp:westbc>"
- + " <lcp:eastbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>-81.9928</lcp:eastbc>"
- + " <lcp:northbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>43.34412</lcp:northbc>"
- + " <lcp:southbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>36.434242</lcp:southbc>"
- + " </CrossCuttingConfigurations>"
- + " </terrain_preprocessortypens:Preprocessor_InputParams>"
- + " </S:Body>"
- + " </S:Envelope>"
- + " </typedSOAPRequest>"
- + " </wor:annotation>"
- + " <wor:request>"
- + " <wor:header>"
- + " <S:Header xmlns:S='http://schemas.xmlsoap.org/soap/envelope/'>"
- + " <lh:context xmlns:lh='http://lead.extreme.indiana.edu/namespaces/2005/10/lead-context-header'>"
- + " <lh:experiment-id>urn:uuid:3f422b0b-912f-49c1-8bb6-0c5612d160bf</lh:experiment-id>"
- + " <lh:event-sink-epr>"
- + " <wsa:Address xmlns:wsa='http://www.w3.org/2005/08/addressing'>http://tyr11.cs.indiana.edu:12346/topic/3f422b0b-912f-49c1-8bb6-0c5612d160bf</wsa:Address>"
- + " </lh:event-sink-epr>"
- + " <lh:user-dn>/O=LEAD Project/OU=portal.leadproject.org/OU=cs.indiana.edu/CN=marcus/EMAIL=machrist@cs.indiana.edu</lh:user-dn>"
- + " <lh:resource-catalog-url>https://everest.extreme.indiana.edu:22443/resource_catalog?wsdl</lh:resource-catalog-url>"
- + " <lh:gfac-url>https://tyr09.cs.indiana.edu:23443?wsdl</lh:gfac-url>"
- + " <lh:mylead-agent-url>https://bitternut.cs.indiana.edu:10243/myleadagent?wsdl</lh:mylead-agent-url>"
- + " <lh:OUTPUT_DATA_DIRECTORY>gsiftp://chinkapin.cs.indiana.edu//data/data-output/3f422b0b-912f-49c1-8bb6-0c5612d160bf</lh:OUTPUT_DATA_DIRECTORY>"
- + " <lh:OPENDAP_DIRECTORY>opendap://chinkapin.cs.indiana.edu:8080/thredds/dodsC/data/data-output/3f422b0b-912f-49c1-8bb6-0c5612d160bf</lh:OPENDAP_DIRECTORY>"
- + " <lh:OUTPUT_DATA_FILES_SUFFIX>.nc</lh:OUTPUT_DATA_FILES_SUFFIX>"
- + " <lh:workflow-instance-id>tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46</lh:workflow-instance-id>"
- + " <lh:resource-broker-url>http://152.54.1.30:3333/resourcebroker?wsdl</lh:resource-broker-url>"
- + " <lh:workflow-time-step>6</lh:workflow-time-step>"
- + " <lh:workflow-node-id>Terrain_Preprocessor</lh:workflow-node-id>"
- + " <lh:service-instance-id>http://tempuri.org/no-service-id</lh:service-instance-id>"
- + " </lh:context>"
- + " <wsa:MessageID xmlns:wsa='http://www.w3.org/2005/08/addressing'>tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46/outgoing/Terrain_PreprocessorPartner/1</wsa:MessageID>"
- + " <wsa:ReplyTo xmlns:wsa='http://www.w3.org/2005/08/addressing'>"
- + " <wsa:Address>http://tyr10.cs.indiana.edu:7080/gpel/728/ADASInitializedWRFForecasting/instance46/incoming/Terrain_PreprocessorPartner.atom</wsa:Address>"
- + " </wsa:ReplyTo>"
- + " <wsa:Action xmlns:wsa='http://www.w3.org/2005/08/addressing'/>"
- + " <wsa:To xmlns:wsa='http://www.w3.org/2005/08/addressing'>https://tyr11.cs.indiana.edu:12554/</wsa:To>"
- + " <wsa:FaultTo xmlns:wsa='http://www.w3.org/2005/08/addressing'>"
- + " <wsa:Address>http://tyr10.cs.indiana.edu:7080/gpel/728/ADASInitializedWRFForecasting/instance46/incoming/Terrain_PreprocessorPartner.atom</wsa:Address>"
- + " </wsa:FaultTo>"
- + " <wsa:RelatesTo xmlns:wsa='http://www.w3.org/2005/08/addressing'>tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46/outgoing/Terrain_PreprocessorPartner/1</wsa:RelatesTo>"
- + " </S:Header>"
- + " </wor:header>"
- + " <wor:body>"
- + " <S:Body xmlns:S='http://schemas.xmlsoap.org/soap/envelope/'>"
- + " <terrain_preprocessortypens:Preprocessor_InputParams xmlns:terrain_preprocessortypens='http://org.apache.airavata/lead/Terrain/xsd'>"
- + " <CrossCuttingConfigurations>"
- + " <lcp:nx xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>53</lcp:nx>"
- + " <lcp:ny xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>53</lcp:ny>"
- + " <lcp:dx xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>20000</lcp:dx>"
- + " <lcp:dy xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>20000</lcp:dy>"
- + " <lcp:fcst_time xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>12.0</lcp:fcst_time>"
- + " <lcp:start_date xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>2007/02/13</lcp:start_date>"
- + " <lcp:start_hour xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>18</lcp:start_hour>"
- + " <lcp:ctrlat xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>39.97712</lcp:ctrlat>"
- + " <lcp:ctrlon xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>-86.484375</lcp:ctrlon>"
- + " <lcp:westbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>-90.97595</lcp:westbc>"
- + " <lcp:eastbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>-81.9928</lcp:eastbc>"
- + " <lcp:northbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>43.34412</lcp:northbc>"
- + " <lcp:southbc xmlns:lcp='http://lead.extreme.indiana.edu/namespaces/2006/lead-crosscut-parameters/'>36.434242</lcp:southbc>"
- + " </CrossCuttingConfigurations>"
- + " </terrain_preprocessortypens:Preprocessor_InputParams>"
- + " </S:Body>"
- + " </wor:body>"
- + " </wor:request>"
- + " <wor:initiator wor:serviceID='tag:gpel.leadproject.org,2006:728/ADASInitializedWRFForecasting/instance46' wor:workflowTimestep='-1'/>"
- + "</wor:serviceInvoked>";
-
- XmlObject test1Obj = XmlObject.Factory.parse(test1);
- List<String> result1 = getSimpleAnnotations(test1Obj, AnnotationConsts.DataProductType);
- for (String obj : result1) {
- System.out.println(obj);
- }
-
- XmlObject test2Obj = XmlObject.Factory.parse(test2);
- List<XmlObject> result2 = getAnnotations(test2Obj, AnnotationConsts.TypedSOAPRequest);
- for (XmlObject obj : result2) {
- System.out.println(obj);
- final String ANNO_XPATH = "declare namespace S='http://schemas.xmlsoap.org/soap/envelope/'"
- + " ./S:Envelope/S:Body/*";
- XmlObject[] out = obj.selectPath(ANNO_XPATH);
- for (XmlObject xo : out) {
- System.out.println("====");
- System.out.println(xo);
- System.out.println("----");
- class Param {
- String paramName, paramType, paramValue;
-
- public Param(String paramName_, String paramType_, String paramValue_) {
- paramName = paramName_;
- paramType = paramType_;
- paramValue = paramValue_;
- }
-
- public String toString() {
- return paramName + "<" + paramType + ">=[" + paramValue + "]";
- }
- }
- List<Param> paramList = new ArrayList<Param>();
-
- XmlCursor xc = xo.newCursor();
- boolean exists = xc.toFirstChild();
- while (exists) {
- String paramName = xc.getName().getLocalPart();
- String paramType = xc.getAttributeText(new QName(
- "http://org.apache.airavata/namespaces/2004/01/gFac", "leadType"));
- String paramValue;
- if ("LeadCrosscutParameters".equals(paramType)) {
- XmlObject paramObj = xc.getObject();
- XmlCursor xc2 = paramObj.newCursor();
- boolean exists2 = xc2.toFirstChild();
- while (exists2) {
- String paramName2 = xc2.getName().getLocalPart();
- String paramValue2 = xc2.getTextValue();
- // get type from param name
- String paramType2; // default
- if ("nx".equals(paramName2) || "ny".equals(paramName2) || "dx".equals(paramName2)
- || "dx".equals(paramName2) || "ctrlat".equals(paramName2)
- || "ctrlon".equals(paramName2) || "westbc".equals(paramName2)
- || "eastbc".equals(paramName2) || "northbc".equals(paramName2)
- || "southbc".equals(paramName2)
- // TODO: add more
- ) {
-
- paramType2 = "Numeric";
- } else {
- // default string
- paramType2 = "String";
- }
-
- paramList.add(new Param(paramName + ":" + paramName2, paramType2, paramValue2));
- exists2 = xc2.toNextSibling();
- }
- } else if ("Integer".equals(paramType)) {
- paramValue = xc.getTextValue();
- paramType = "Numeric";
- paramList.add(new Param(paramName, paramType, paramValue));
- } else if ("Nominal".equals(paramType)) {
- paramValue = xc.getTextValue();
- paramType = "Nominal";
- paramList.add(new Param(paramName, paramType, paramValue));
- } else {
- // default
- paramValue = xc.getTextValue();
- paramType = "String";
- paramList.add(new Param(paramName, paramType, paramValue));
- }
- exists = xc.toNextSibling();
- }
- // return paramList;
-
- for (Param p : paramList) {
- System.out.println(p);
- }
- }
- }
- }
-
- public static void testTimestamp(String[] args) throws Exception {
- final String ACTIVITY = "<wor:serviceInvoked infoModelVersion='2.6' xmlns:wor='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'><wor:notificationSource wor:serviceID='urn:qname:http://org.apache.airavata/lead:FactoryService_Fri_Jun_22_21_21_24_EDT_2007_311971' wor:workflowID='tag:gpel.leadproject.org,2006:76M/Challenge2WorkflowPartI/instance5' wor:workflowTimestep='6' wor:workflowNodeID='GFac:AlignWarpService_Run'/><wor:timestamp>2007-06-23T11:16:35.404-04:00</wor:timestamp><wor:description>Service Invoked</wor:description><wor:annotation><n1:typedSOAPRequest xmlns:n1='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'><S:Envelope xmlns:xsd='http://www.w3.org/2001/XMLSchema' xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' xmlns:wsa='http://www.w3.org/2005/08/addressing' xmlns:wsp='http://schemas.xmlsoap.org/ws/2002/12/policy' xmlns:S='http://schemas.xmlsoap.org/soap/envelope/'><S:Header><lh:context xmlns:lh='http://lead.extreme.i
ndiana.edu/namespaces/2005/10/lead-context-header'><lh:experiment-id>xbaya-experiment</lh:experiment-id><lh:event-sink-epr><wsa:Address>http://tyr10.cs.indiana.edu:12346/topic/second-provenance-challenge-20070623T111715</wsa:Address></lh:event-sink-epr><lh:user-dn>/O=LEAD Project/OU=Indiana University Extreme Lab/OU=linbox1.extreme.indiana.edu/OU=extreme.indiana.edu/CN=ysimmhan/EMAIL=ysimmhan@cs.indiana.edu</lh:user-dn><lh:resource-catalog-url>https://everest.extreme.indiana.edu:20443/resource_catalog?wsdl</lh:resource-catalog-url><lh:gfac-url>https://tyr12.cs.indiana.edu:23443/?wsdl</lh:gfac-url><lh:mylead-agent-url>https://tyr03.cs.indiana.edu:20243/myleadagent?wsdl</lh:mylead-agent-url><lh:workflow-template-id>tag:gpel.leadproject.org,2006:76M/Challenge2WorkflowPartI</lh:workflow-template-id><lh:workflow-instance-id>tag:gpel.leadproject.org,2006:76M/Challenge2WorkflowPartI/instance5</lh:workflow-instance-id><lh:workflow-time-step>6</lh:workflow-time-step><lh:workflow-node-id>GFac
:AlignWarpService_Run</lh:workflow-node-id><lh:service-instance-id>http://tempuri.org/no-service-id</lh:service-instance-id></lh:context><wsa:To>https://tyr12.cs.indiana.edu:23443/</wsa:To><wsa:Action>http://org.apache.airavata/lead/FactoryService/CreateService</wsa:Action></S:Header><S:Body><n1:CreateService_InputParams xmlns:n1='http://org.apache.airavata/lead/FactoryService/xsd'><serviceQName n2:leadType='String' xmlns:n2='http://org.apache.airavata/namespaces/2004/01/gFac'>{http://org.apache.airavata/karma/challenge2}AlignWarpService</serviceQName><security n3:leadType='String' xmlns:n3='http://org.apache.airavata/namespaces/2004/01/gFac'>None</security><registryUrl n4:leadType='String' xmlns:n4='http://org.apache.airavata/namespaces/2004/01/gFac'/><host n5:leadType='String' xmlns:n5='http://org.apache.airavata/namespaces/2004/01/gFac'/><appHost n6:leadType='String' xmlns:n6='http://org.apache.airavata/namespaces/2004/01/gFac'/></n1:CreateService_InputParams></S:Body></S:Envelop
e></n1:typedSOAPRequest><n1:experimentID xmlns:n1='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>xbaya-experiment</n1:experimentID><n1:userDN xmlns:n1='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>/O=LEAD Project/OU=Indiana University Extreme Lab/OU=linbox1.extreme.indiana.edu/OU=extreme.indiana.edu/CN=ysimmhan/EMAIL=ysimmhan@cs.indiana.edu</n1:userDN><experimentID xmlns='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>xbaya-experiment</experimentID></wor:annotation><wor:request><wor:header><S:Header xmlns:S='http://schemas.xmlsoap.org/soap/envelope/'><lh:context xmlns:lh='http://lead.extreme.indiana.edu/namespaces/2005/10/lead-context-header'><lh:experiment-id>xbaya-experiment</lh:experiment-id><lh:event-sink-epr><wsa:Address xmlns:wsa='http://www.w3.org/2005/08/addressing'>http://tyr10.cs.indiana.edu:12346/topic/second-provenance-challenge-20070623T111715</wsa:Address></lh:event-sink-epr><lh:user-dn>/O=LEAD Pro
ject/OU=Indiana University Extreme Lab/OU=linbox1.extreme.indiana.edu/OU=extreme.indiana.edu/CN=ysimmhan/EMAIL=ysimmhan@cs.indiana.edu</lh:user-dn><lh:resource-catalog-url>https://everest.extreme.indiana.edu:20443/resource_catalog?wsdl</lh:resource-catalog-url><lh:gfac-url>https://tyr12.cs.indiana.edu:23443/?wsdl</lh:gfac-url><lh:mylead-agent-url>https://tyr03.cs.indiana.edu:20243/myleadagent?wsdl</lh:mylead-agent-url><lh:workflow-template-id>tag:gpel.leadproject.org,2006:76M/Challenge2WorkflowPartI</lh:workflow-template-id><lh:workflow-instance-id>tag:gpel.leadproject.org,2006:76M/Challenge2WorkflowPartI/instance5</lh:workflow-instance-id><lh:workflow-time-step>6</lh:workflow-time-step><lh:workflow-node-id>GFac:AlignWarpService_Run</lh:workflow-node-id><lh:service-instance-id>http://tempuri.org/no-service-id</lh:service-instance-id></lh:context><wsa:To xmlns:wsa='http://www.w3.org/2005/08/addressing'>https://tyr12.cs.indiana.edu:23443/</wsa:To><wsa:Action xmlns:wsa='http://www.w3.o
rg/2005/08/addressing'>http://org.apache.airavata/lead/FactoryService/CreateService</wsa:Action></S:Header></wor:header><wor:body><S:Body xmlns:S='http://schemas.xmlsoap.org/soap/envelope/'><n1:CreateService_InputParams xmlns:n1='http://org.apache.airavata/lead/FactoryService/xsd'><serviceQName>{http://org.apache.airavata/karma/challenge2}AlignWarpService</serviceQName><security>None</security><registryUrl/><host/><appHost/></n1:CreateService_InputParams></S:Body></wor:body></wor:request><wor:initiator wor:serviceID='tag:gpel.leadproject.org,2006:76M/Challenge2WorkflowPartI/instance5' wor:workflowTimestep='-1'/></wor:serviceInvoked>";
- XmlObject activity = XmlObject.Factory.parse(ACTIVITY);
- System.out.println(getActivityTimestamp(activity));
- System.out.println(getActivityWorkflowTimestep(activity));
- }
-
- public static void main(String[] args) throws XmlException, ParseException {
- final String ACTIVITY = "<wor:dataConsumed xmlns:wor='http://lead.extreme.indiana.edu/namespaces/2006/06/workflow_tracking'>"
- + "<wor:notificationSource wor:serviceID='urn:qname:http://org.apache.airavata/karma/challenge2:AlignWarpService_Wed_Feb_21_12_09_49_EST_2007_67130' wor:workflowID='tag:gpel.leadproject.org,2006:72L/Challenge2WorkflowPartI/instance2' wor:workflowTimestep='6' wor:workflowNodeID='AlignWarpService_Run'/>"
- + "<wor:timestamp>2007-02-21T12:10:33.772-05:00</wor:timestamp>"
- + "<wor:dataProduct>"
- + "<wor:id>urn:leadproject-org:data:3d847d61-696e-4742-b98b-51f39aa2c679</wor:id>"
- + "<wor:location>gsiftp://tyr15.cs.indiana.edu//san/extreme/tmp/service_logs/development/AlignWarp_Wed_Feb_21_12_09_57_EST_2007_17/inputData/anatomy1.img</wor:location>"
- + "<wor:sizeInBytes>-1</wor:sizeInBytes>"
- + "<wor:timestamp>2007-02-21T12:10:33.771-05:00</wor:timestamp>"
- + "<wor:description>gsiftp://tyr15.cs.indiana.edu//san/extreme/tmp/service_logs/development/AlignWarp_Wed_Feb_21_12_09_57_EST_2007_17/inputData/anatomy1.img</wor:description>"
- + "<wor:annotation>"
- + "<type xmlns='http://org.apache.airavata/namespaces/2004/01/gFac'>DataID</type>"
- + "<center xmlns='http://twiki.ipaw.info/bin/view/Challenge/SecondProvenanceChallenge'>UChicago</center>"
- + "</wor:annotation>" + "</wor:dataProduct>" + "</wor:dataConsumed>";
-
- XmlObject activity = XmlObject.Factory.parse(ACTIVITY);
- Map<QName, String> annos = getSimpleAnnotations(activity);
- for (Map.Entry<QName, String> anno : annos.entrySet()) {
- System.out.println(anno);
- }
-
- }
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/Timer.java
----------------------------------------------------------------------
diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/Timer.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/Timer.java
deleted file mode 100644
index 47bed09..0000000
--- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/Timer.java
+++ /dev/null
@@ -1,104 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.workflow.tracking.util;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * calculates simple timing information for instrumenting code
- */
-public class Timer {
-
- private static final Logger logger = LoggerFactory.getLogger(Timer.class);
-
- private long start, end, total = 0, deltaStart, delta = 0;
- private final String msg;
- private boolean ended = false, started = false, paused = false, terminated = false;
-
- Timer(String msg_) {
- msg = msg_;
- start = System.currentTimeMillis();
- }
-
- public static Timer init(String msg_) {
- return new Timer(msg_);
- }
-
- public static Timer initAndStart(String msg_) {
-
- Timer tp = new Timer(msg_);
- tp.start();
- return tp;
- }
-
- public void start() {
-
- assert started == false && terminated == false;
- started = true;
- ended = false;
- start = System.currentTimeMillis();
- }
-
- public boolean startOrContinue() {
-
- if (started)
- return false; // continued...not started fresh
- start();
- return true; // started fresh
- }
-
- public long end(String msg_) {
-
- assert started == true && terminated == false;
- end = System.currentTimeMillis();
- total += (end - start - delta);
- logger.debug("\n!T!ENDOne \t" + msg_ + " \t" + (end - start - delta) + "\t millis of \t" + total);
- ended = true;
- return end - start;
- }
-
- public long end() {
- return end(msg);
- }
-
- public long endAll() {
-
- logger.debug("\n!T!ENDAll \t" + msg + " \t" + total);
- terminated = true;
- return total;
- }
-
- public void pause() {
-
- assert started == true && terminated == false;
- deltaStart = System.currentTimeMillis();
- paused = true;
- }
-
- public void resume() {
-
- assert paused == true && terminated == false;
- paused = false;
- delta = System.currentTimeMillis() - deltaStart;
- }
-};
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/XmlBeanUtils.java
----------------------------------------------------------------------
diff --git a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/XmlBeanUtils.java b/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/XmlBeanUtils.java
deleted file mode 100644
index d65004d..0000000
--- a/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/util/XmlBeanUtils.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.airavata.workflow.tracking.util;
-
-import org.apache.airavata.workflow.tracking.types.BaseNotificationType;
-import org.apache.xmlbeans.XmlCursor;
-import org.apache.xmlbeans.XmlObject;
-
-public class XmlBeanUtils {
-
- public static BaseNotificationType extractBaseNotificationType(XmlObject xmldata) {
- XmlCursor c = xmldata.newCursor();
- c.toNextToken();
- BaseNotificationType type = (BaseNotificationType) c.getObject();
- c.dispose();
- return type;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/resources/log4j.properties
----------------------------------------------------------------------
diff --git a/modules/commons/workflow-tracking/src/main/resources/log4j.properties b/modules/commons/workflow-tracking/src/main/resources/log4j.properties
deleted file mode 100644
index 598ee12..0000000
--- a/modules/commons/workflow-tracking/src/main/resources/log4j.properties
+++ /dev/null
@@ -1,82 +0,0 @@
-#
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-#
-
-#------------------------------------------------------------------------------
-#
-# The following properties set the logging levels and log appender. The
-# log4j.rootCategory variable defines the default log level and one or more
-# appenders. For the console, use 'S'. For the daily rolling file, use 'R'.
-# For an HTML formatted log, use 'H'.
-#
-# To override the default (rootCategory) log level, define a property of the
-# form (see below for available values):
-#
-# log4j.logger. =
-#
-# Available logger names:
-# TODO
-#
-# Possible Log Levels:
-# FATAL, ERROR, WARN, INFO, DEBUG
-#
-#------------------------------------------------------------------------------
-log4j.rootCategory=FATAL,S
-
-
-log4j.logger.com.dappit.Dapper.parser=ERROR
-log4j.logger.org.w3c.tidy=FATAL
-
-#------------------------------------------------------------------------------
-#
-# The following properties configure the console (stdout) appender.
-# See http://logging.apache.org/log4j/docs/api/index.html for details.
-#
-#------------------------------------------------------------------------------
-log4j.appender.S = org.apache.log4j.ConsoleAppender
-log4j.appender.S.layout = org.apache.log4j.PatternLayout
-log4j.appender.S.layout.ConversionPattern = %d{yyyy-MM-dd HH:mm:ss} %c{1} [%p] %m%n
-log4j.appender.S.Threshold=ERROR
-
-#------------------------------------------------------------------------------
-#
-# The following properties configure the Daily Rolling File appender.
-# See http://logging.apache.org/log4j/docs/api/index.html for details.
-#
-#------------------------------------------------------------------------------
-log4j.appender.R = org.apache.log4j.DailyRollingFileAppender
-log4j.appender.R.File = logs/workflow.log
-log4j.appender.R.Append = true
-log4j.appender.R.DatePattern = '.'yyy-MM-dd
-log4j.appender.R.layout = org.apache.log4j.PatternLayout
-log4j.appender.R.layout.ConversionPattern = %d{yyyy-MM-dd HH:mm:ss} %c{1} [%p] %m%n
-
-#------------------------------------------------------------------------------
-#
-# The following properties configure the Rolling File appender in HTML.
-# See http://logging.apache.org/log4j/docs/api/index.html for details.
-#
-#------------------------------------------------------------------------------
-log4j.appender.H = org.apache.log4j.RollingFileAppender
-log4j.appender.H.File = logs/workflow.html
-log4j.appender.H.MaxFileSize = 100KB
-log4j.appender.H.Append = false
-log4j.appender.H.layout = org.apache.log4j.HTMLLayout
-log4j.appender.S.Threshold=FATAL
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsd
----------------------------------------------------------------------
diff --git a/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsd b/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsd
deleted file mode 100644
index f4bdf96..0000000
--- a/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsd
+++ /dev/null
@@ -1,594 +0,0 @@
-<?xml version='1.0' encoding='utf-8' ?>
-<!--Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under
- the Apache License, Version 2.0 (theÏ "License"); you may not use this file except in compliance with the License. You may
- obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to
- in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
- ANY ~ KIND, either express or implied. See the License for the specific language governing permissions and limitations under
- the License. -->
-
-<schema targetNamespace="http://airavata.apache.org/schemas/wft/2011/08" xmlns:wft="http://airavata.apache.org/schemas/wft/2011/08"
- xmlns="http://www.w3.org/2001/XMLSchema" attributeFormDefault="qualified" elementFormDefault="qualified">
-
- <annotation>
- <documentation>
- *) Workflows and services can be abstract (template) or concrete (instance).
- Unless otherwise noted, we always refer to the concrete instance of the workflow/service below
- *) All workflows are also services.
- *) Services may be part of zero or more workflows
- *) When Services execute in the context of a workflow,
- an invocation of the service is associated with the workflowID of the workflow whose context
- in which it is being invoked (also called parent workflow),
- the timestep of this invocation in the parent workflow,
- and the node ID that uniquely identifies this service within the parent workflow instance.
- *) Workflows can also be invoked in the context of another parent workflow.
- *) Workflow ID always refers to the "parent workflow ID". When refering to the invocation of a workflow,
- its instance ID is called the Service ID.
- *) Workflows that are not invoked from another workflow do not have a context of execution
- (parent workflow is not present => Workflow ID is NULL)
- *) Schema design notes
- - This schema uses the "Venetian Blind" schema design pattern
- - It uses Upper Camel Case for schema types and lower camel case for
- element and attribute names
- </documentation>
- </annotation>
-
- <simpleType name="ServiceIDType">
- <annotation>
- <documentation>
- ID to uniquely identify the service instance.
- This is usually formed from the targetnamespace and porttype name of the service's WSDL.
- This ID may refer to the instance ID for a service or for a workflow.
- </documentation>
- </annotation>
- <restriction base="anyURI" />
- </simpleType>
-
- <simpleType name="WorkflowNodeIDType">
- <annotation>
- <documentation>
- String that identifies uniquely a node in workflow graph.
- The node ID is unique in the scope of a workflow ID.
- </documentation>
- </annotation>
- <restriction base="string" />
- </simpleType>
-
- <simpleType name="WorkflowTimestepType">
- <annotation>
- <documentation>
- The timestep within workflow execution at which this invocation is made.
- This is a logical time that monotonically increments for each invocation in a workflow.
- </documentation>
- </annotation>
- <restriction base="int" />
- </simpleType>
-
- <simpleType name="DataProductIDType">
- <annotation>
- <documentation>
- Unique logical ID for a data product in the form of a UUID.
- Physical URL for the data products can be resolved using this ID.
- </documentation>
- </annotation>
- <restriction base="anyURI" />
- </simpleType>
-
- <simpleType name="ExperimentIDType">
- <annotation>
- <documentation>
- String that identifies uniquely a node in workflow graph.
- The node ID is unique in the scope of a workflow ID.
- </documentation>
- </annotation>
- <restriction base="string" />
- </simpleType>
-
- <!-- ========================================================================================== -->
-
- <complexType name="BaseIDType">
- <attribute name="workflowID" type="wft:ServiceIDType" use="optional">
- <annotation>
- <documentation>
- The workflow context within which this service is executing.
- If this service is itself a workflow and not executing as part of another workflow
- (i.e. this is the root of the invocation trace) then the workflow ID is absent.
- Otherwise, this is the service ID of the workflow instance.
- </documentation>
- </annotation>
- </attribute>
-
- <attribute name="serviceID" type="wft:ServiceIDType" use="required">
- <annotation>
- <documentation>
- ID to uniquely identify a service instance. The service instance can
- be part of zero or more workflow.
- This is formed from the targetnamespace of the service's CWSDL.
- </documentation>
- </annotation>
- </attribute>
-
- <attribute name="experimentID" type="wft:ExperimentIDType" use="required">
- <annotation>
- <documentation>
- ID to uniquely identify a workflow invocation.
- </documentation>
- </annotation>
- </attribute>
-
- <attribute name="workflowNodeID" type="wft:WorkflowNodeIDType" use="optional">
- <annotation>
- <documentation>
- Distinct ID of a node within a Workflow graph. unique within the workflowID,
- not necessarily the order of execution.
- </documentation>
- </annotation>
- </attribute>
-
- <attribute name="workflowTimestep" type="wft:WorkflowTimestepType" use="optional">
- <annotation>
- <documentation>
- The timestep within workflow execution at which this invocation is made.
- 32bit integer. Timestep is a numerically ordered monotonically increasing sequence
- within wf execution that allows relative ordering of invocations.
- It is unique within the workflowID for each invocation in the workflow.
- </documentation>
- </annotation>
- </attribute>
- </complexType>
-
- <!-- base type for all notifications -->
- <complexType name="BaseNotificationType">
- <annotation>
- <documentation>This is the base type for all notification activities that are produced</documentation>
- </annotation>
- <sequence>
-
- <element name="notificationSource" type="wft:BaseIDType">
- <annotation>
- <documentation>
- This identifies the entity/invocation context from which this notifcation is being sent.
- </documentation>
- </annotation>
- </element>
-
- <element name="timestamp" type="dateTime" />
-
- <element name="description" type="string" minOccurs="0">
- <annotation>
- <documentation>Optional human friendly description of this notification.</documentation>
- </annotation>
- </element>
-
- <element name="annotation" type="anyType" minOccurs="0">
- <annotation>
- <documentation>Optional additional metadata for this notification. See common.AnnotationConsts file.
- </documentation>
- </annotation>
- </element>
-
- </sequence>
-
- <attribute name="infoModelVersion" form="unqualified" type="NMTOKEN" use="required">
- <!-- we set form as unqualified to allow WS-Messenger YFilter to match it -->
- <!-- NMToken := (Letter | Digit | '.' | '-' | '_' | ':')+ -->
- <annotation>
- <documentation>
- String identifying notification schema version (used for verifying compatible schema and filtering).
- </documentation>
- </annotation>
- </attribute>
-
- </complexType>
-
-
- <complexType name="MessageType">
- <sequence>
- <element name="header" type="anyType" minOccurs="0" /> <!-- e.g. soap:header -->
- <element name="body" type="anyType" minOccurs="0" /> <!-- e.g. soap:body --> <!-- fixme: change to message -->
- </sequence>
- </complexType>
-
- <complexType name="FaultMessageType">
- <complexContent>
- <extension base="wft:MessageType" />
- </complexContent>
- </complexType>
-
- <complexType name="InvocationMessageType">
- <complexContent>
- <extension base="wft:MessageType" />
- </complexContent>
- </complexType>
-
-
- <complexType name="FailureMessageType">
- <sequence>
- <element name="trace" type="anyType" minOccurs="0" maxOccurs="unbounded" />
- </sequence>
- </complexType>
-
-
- <!-- ========================================================================================== -->
- <!-- workflow provenance types -->
- <!-- ========================================================================================== -->
-
- <!-- sent when the service is first created and is ready to accept invocations -->
- <element name="serviceInitialized" type="wft:BaseNotificationType" />
-
- <!-- sent when the service is terminated and will not accept any further invocations -->
- <element name="serviceTerminated" type="wft:BaseNotificationType" />
-
- <!-- sent when the workflow is first created and is ready to accept invocations -->
- <!--element name="workflowInitialized" type="wft:BaseNotificationType" -->
- <element name="workflowInitialized">
- <complexType>
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="initialPriority" type="string" minOccurs="0" />
- <element name="workflowTemplateId" type="wft:ServiceIDType" minOccurs="0" />
- <element name="workflowCreatorDn" type="string" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
- </element>
-
- <!-- sent when the workflow is terminated and will not accept any further invocations -->
- <element name="workflowTerminated" type="wft:BaseNotificationType" />
-
- <!-- sent when the workflow execution is paused: invocations will be accepted but no new messages will be sent by the workflow -->
- <element name="workflowPaused" type="wft:BaseNotificationType" />
-
- <!-- sent when the workflow execution is resumed -->
- <element name="workflowResumed" type="wft:BaseNotificationType" />
-
- <!-- workflow priority tracking -->
- <element name="workflowPriorityChanged">
- <complexType>
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="newPriority" type="string" />
- <element name="oldPriority" type="string" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
- </element>
-
- <!-- ========================================================================================== -->
-
- <complexType name="InvocationRequestType" abstract="true">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="request" type="wft:InvocationMessageType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="RequestInitiatorType">
- <complexContent>
- <extension base="wft:InvocationRequestType">
- <sequence>
- <!-- used by wf (client) to set service info, when invoking service -->
- <element name="receiver" type="wft:BaseIDType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="RequestReceiverType">
- <complexContent>
- <extension base="wft:InvocationRequestType">
- <sequence>
- <!-- used by service to set workflow(client) info, when invoked by workflow (client) -->
- <element name="initiator" type="wft:BaseIDType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
-
- <!-- ========================================================================================== -->
-
- <complexType name="AcknowledgementType" abstract="true">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="receiver" type="wft:BaseIDType" minOccurs="0" /> <!-- target of the action that succeeded -->
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="AcknowledgeSuccessType">
- <complexContent>
- <extension base="wft:AcknowledgementType" />
- </complexContent>
- </complexType>
-
- <complexType name="AcknowledgeFailureType">
- <complexContent>
- <extension base="wft:AcknowledgementType">
- <sequence>
- <element name="failure" type="wft:FailureMessageType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <!-- ========================================================================================== -->
-
- <!-- sent by workflow when a service is invoked by it. -->
- <element name="invokingService" type="wft:RequestInitiatorType" />
-
-
- <!-- sent by workflow when it is invoked. -->
- <element name="workflowInvoked" type="wft:RequestReceiverType" />
-
- <!-- sent by service when it is invoked. -->
- <element name="serviceInvoked" type="wft:RequestReceiverType" />
-
-
- <!-- sent by workflow when it invoked a service successfully. -->
- <element name="invokingServiceSucceeded" type="wft:AcknowledgeSuccessType" />
-
- <!-- sent by workflow when it failed to invoke a service successfully. -->
- <element name="invokingServiceFailed" type="wft:AcknowledgeFailureType" />
-
-
- <!-- ========================================================================================== -->
-
- <complexType name="InvocationResultType" abstract="true">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="result" type="wft:InvocationMessageType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="InvocationFaultType" abstract="true">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="fault" type="wft:FaultMessageType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="ResultReceiverType">
- <complexContent>
- <extension base="wft:InvocationResultType">
- <sequence>
- <!-- used by wf (client) to set service info, when receiving result from service -->
- <element name="responder" type="wft:BaseIDType" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="FaultReceiverType">
- <complexContent>
- <extension base="wft:InvocationFaultType">
- <sequence>
- <!-- used by wf (client) to set service info, when receiving result from service -->
- <element name="responder" type="wft:BaseIDType" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="ResultResponderType">
- <complexContent>
- <extension base="wft:InvocationResultType">
- <sequence>
- <!-- used by service to set workflow(client) info, when returning result to workflow (client) -->
- <element name="receiver" type="wft:BaseIDType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="FaultResponderType">
- <complexContent>
- <extension base="wft:InvocationFaultType">
- <sequence>
- <!-- used by service to set workflow(client) info, when returning result to workflow (client) -->
- <element name="receiver" type="wft:BaseIDType" minOccurs="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <!-- ========================================================================================== -->
-
- <!-- sent by service when it returns the result for an invocation. -->
- <element name="sendingResult" type="wft:ResultResponderType" /> <!-- add workflowSendingResult -->
-
- <!-- sent by service when it returns a fault for an invocation. -->
- <element name="sendingFault" type="wft:FaultResponderType" /> <!-- add workflowSendingFault -->
-
-
- <!-- sent by workflow when it receives the result for an invocation. -->
- <element name="receivedResult" type="wft:ResultReceiverType" /> <!-- add workflowReceivedResult -->
-
- <!-- sent by workflow when it receives a fault for an invocation. -->
- <element name="receivedFault" type="wft:FaultReceiverType" /> <!-- add workflowFaultResult -->
-
-
- <!-- sent by service when it has successfully sent the result for an invocation. -->
- <element name="sendingResponseSucceeded" type="wft:AcknowledgeSuccessType" />
-
- <!-- sent by service when it has successfully sent a fault for an invocation. -->
- <element name="sendingResponseFailed" type="wft:AcknowledgeFailureType" />
-
- <!-- ========================================================================================== -->
-
-
- <!-- ========================================================================================== -->
- <!-- data provenance types -->
- <!-- ========================================================================================== -->
-
- <!-- general complex data types -->
- <complexType name="DataProductType">
- <sequence>
- <element name="id" type="wft:DataProductIDType" />
- <element name="location" type="anyURI" minOccurs="0" maxOccurs="unbounded" />
- <element name="sizeInBytes" type="long" minOccurs="0" />
- <element name="timestamp" type="dateTime" minOccurs="0" /> <!-- context sensitive. time at which data product was produced or consumed. -->
- <element name="description" type="string" minOccurs="0">
- <annotation>
- <documentation>Optional human friendly description of this data product.</documentation>
- </annotation>
- </element>
- <element name="annotation" type="anyType" minOccurs="0">
- <annotation>
- <documentation>Optional additional metadata for this data product.</documentation>
- </annotation>
- </element>
- </sequence>
- </complexType>
-
- <complexType name="DataProductNotificationType">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="dataProduct" type="wft:DataProductType" minOccurs="0" maxOccurs="unbounded" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <!-- sent when a file is used by the jython app. -->
- <element name="dataConsumed" type="wft:DataProductNotificationType" />
-
- <!-- sent when a file is generated by the jython app. -->
- <element name="dataProduced" type="wft:DataProductNotificationType" />
-
-
- <!-- ========================================================================================== -->
- <!-- performance audit types -->
- <!-- ========================================================================================== -->
-
-
- <!-- sent when the application launches a GRAM job, to facilitate -->
- <!-- auditing and accounting of TeraGrid jobs -->
- <!-- SJ The type name needed Type added at the end -->
- <complexType name="ApplicationAuditType">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="name" type="string" />
- <element name="jobHandle" type="anyURI" />
- <element name="host" type="string" />
- <element name="queueName" type="string" minOccurs="0" />
- <element name="jobId" type="string" minOccurs="0" />
- <element name="distinguishedName" type="string" />
- <element name="projectId" type="string" minOccurs="0" />
- <element name="rsl" type="string" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <element name="applicationAudit" type="wft:ApplicationAuditType" />
-
-
- <!-- sent at the end of a computational block in the jython app -->
- <!-- with the time in milliseconds taken for that computational block -->
- <element name="computationDuration">
- <complexType>
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="durationInMillis" type="long" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
- </element>
-
- <!-- sent at the end of sending a file to remote location (thro' gridftp?) by the jython app -->
- <!-- with the time in milliseconds taken to send that file -->
- <!-- TODO: later add support for time for multiple files in a single notification? -->
- <complexType name="DataTransferDurationType">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="id" type="wft:DataProductIDType" />
- <element name="source" type="anyURI" />
- <element name="target" type="anyURI" />
- <element name="sizeInBytes" type="long" minOccurs="0" default="-1" />
- <element name="durationInMillis" type="long" default="-1" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <element name="dataSendDuration" type="wft:DataTransferDurationType" />
- <element name="dataReceiveDuration" type="wft:DataTransferDurationType" />
-
- <!-- ========================================================================================== -->
- <!-- generic log message types -->
- <!-- ========================================================================================== -->
-
-
- <!-- sent when an interesting file is created by the jython app that can be viewed thro' a URL -->
- <!-- used to display as a link on the portal -->
- <element name="publishURL">
- <complexType>
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="title" type="string" minOccurs="0" />
- <element name="location" type="anyURI" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
- </element>
-
- <!-- generic log message at different levels of importance that can be produced by the jython app -->
- <element name="logInfo" type="wft:BaseNotificationType" />
- <element name="logException" type="wft:BaseNotificationType" />
- <element name="logWarning" type="wft:BaseNotificationType" />
- <element name="logDebug" type="wft:BaseNotificationType" />
-
-
- <!-- ========================================================================================== -->
- <!-- resource broker message types -->
- <!-- ========================================================================================== -->
-
- <complexType name="ResourceMappingType">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="mappedResource" type="string" />
- <element name="retryStatusCount" type="int" default="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <complexType name="JobStatusType">
- <complexContent>
- <extension base="wft:BaseNotificationType">
- <sequence>
- <element name="jobStatus" type="string" />
- <element name="retryCount" type="int" default="0" />
- </sequence>
- </extension>
- </complexContent>
- </complexType>
-
- <element name="resourceMapping" type="wft:ResourceMappingType" />
- <element name="jobStatus" type="wft:JobStatusType" />
-
-</schema>
http://git-wip-us.apache.org/repos/asf/airavata/blob/42f77edb/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsdconfig
----------------------------------------------------------------------
diff --git a/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsdconfig b/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsdconfig
deleted file mode 100755
index bb1101b..0000000
--- a/modules/commons/workflow-tracking/src/main/resources/schemas/workflow_tracking_types.xsdconfig
+++ /dev/null
@@ -1,21 +0,0 @@
-<!--Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under
- the Apache License, Version 2.0 (theÏ "License"); you may not use this file except in compliance with the License. You may
- obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to
- in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
- ANY ~ KIND, either express or implied. See the License for the specific language governing permissions and limitations under
- the License. -->
-
-<!-- An xsdconfig file must begin with a "config" element in the
- http://www.bea.com/2002/09/xbean/config namespace. Also, be sure
- to declare any namespaces used to qualify types in your schema (here,
- the namespace corresponding to the pol prefix. -->
-<xb:config xmlns:xb="http://www.bea.com/2002/09/xbean/config">
-
- <!-- Use the "namespace" element to map a namespace to the Java package
- name that should be generated. -->
- <xb:namespace uri="http://airavata.apache.org/schemas/wft/2011/08">
- <xb:package>org.apache.airavata.workflow.tracking.types</xb:package>
- </xb:namespace>
-
-</xb:config>