Author: sumarlidason
Date: Mon Jun 24 15:22:39 2013
New Revision: 1496091
URL: http://svn.apache.org/r1496091
Log:
[OODT-641] adding python examples/wrapper class for workflow manager xmlrpc
Added:
oodt/trunk/workflow/src/main/python/
oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/
oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_metadata.py
oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_workflow_xmlrpc.py
Added: oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_metadata.py
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_metadata.py?rev=1496091&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_metadata.py (added)
+++ oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_metadata.py Mon Jun
24 15:22:39 2013
@@ -0,0 +1,29 @@
+# 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.
+
+
+class MetaData(object):
+ def __init__(self):
+ self.data = {}
+
+ def addMetaData(self, key, value):
+ if key not in self.data:
+ self.data[key] = []
+ self.data[key].append(value)
+
+ def toXmlRpc(self):
+ return self.data
Added:
oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_workflow_xmlrpc.py
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_workflow_xmlrpc.py?rev=1496091&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_workflow_xmlrpc.py
(added)
+++ oodt/trunk/workflow/src/main/python/xmlrpc-wrapper/oodt_workflow_xmlrpc.py
Mon Jun 24 15:22:39 2013
@@ -0,0 +1,134 @@
+# 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.
+
+
+import xmlrpclib
+from oodt_metadata import MetaData
+
+
+class OODTWorkFlowWrapper(object):
+ def __init__(self, host):
+ self._server = xmlrpclib.Server(host)
+
+ #String executeDynamicWorkflow(Vector<String> taskIds, Hashtable
metadata)
+ def executeDynamicWorkflow(self, taskIds, metadata):
+ return self._server.workflowmgr.executeDynamicWorkflow(taskIds,
metadata)
+ #Hashtable getConditionById(String conditionId)
+ def getConditionById(self, conditionId):
+ return self._server.workflowmgr.getConditionById(conditionId)
+ #Hashtable getFirstPage()
+ def getFirstPage(self):
+ return self._server.workflowmgr.getFirstPage()
+ #Hashtable getLastPage()
+ def getLastPage(self):
+ return self._server.workflowmgr.getLastPage()
+ #Hashtable getNextPage(Hashtable currentPage)
+ def getNextPage(self, currentPage):
+ return self._server.workflowmgr.getNextPage()
+ #int getNumWorkflowInstances()
+ def getNumWorkflowInstances(self):
+ return self._server.workflowmgr.getNumWorkflowInstances()
+ #int getNumWorkflowInstancesByStatus(String status)
+ def getNumWorkflowInstancesByStatus(self, status):
+ return
self._server.workflowmgr.getNumWorkflowInstancesByStatus(status)
+ #Hashtable getPrevPage(Hashtable currentPage)
+ def getPrevPage(self, currentPage):
+ return self._server.workflowmgr.getPrevPage(currentPage)
+ #Vector getRegisteredEvents()
+ def getEventNames(self):
+ return self._server.workflowmgr.getRegisteredEvents()
+ #Hashtable getTaskById(String taskId)
+ def getTaskById(self, taskId):
+ return self._server.workflowmgr.getTaskById(taskId)
+ #Hashtable getWorkflowById(String workflowId)
+ def getWorkflowById(self, workflowId):
+ return self._server.workflowmgr.getWorkflowById(workflowId)
+ #double getWorkflowCurrentTaskWallClockMinutes(String
workflowInstId)
+ def getWorkflowCurrentTaskWallClockMinutes(self, workflowInstId):
+ return
self._server.workflowmgr.getWorkflowCurrentTaskWallClockMinutes(workflowInstId)
+ #Hashtable getWorkflowInstanceById(String wInstId)
+ def getWorkflowInstanceById(self,wInstId):
+ return self._server.workflowmgr.getWorkflowInstanceById(wInstId)
+ #Hashtable getWorkflowInstanceMetadata(String wInstId)
+ def getWorkflowInstanceMetadata(self, wInstId):
+ return
self._server.workflowmgr.getWorkflowInstanceMetadata(wInstId)
+ #Vector getWorkflowInstances()
+ def getWorkflowInstances(self):
+ return self._server.workflowmgr.getWorkflowInstances()
+ #Vector getWorkflowInstancesByStatus(String status)
+ def getWorkflowInstancesByStatus(self, status):
+ return
self._server.workflowmgr.getWorkflowInstancesByStatus(status)
+ #Vector getWorkflows()
+ def getWorkflows(self):
+ return self._server.workflowmgr.getWorkflows()
+ #Vector getWorkflowsByEvent(String eventName)
+ def getWorkflowsByEvent(self, eventName):
+ return self._server.workflowmgr.getWorkflowsByEvent(eventName)
+ #double getWorkflowWallClockMinutes(String workflowInstId)
+ def getWorkflowWallClockMinutes(self,workflowInstId):
+ return getWorkflowWallClockMinutes(workflowInstId)
+ #boolean handleEvent(String eventName, Hashtable metadata)
+ def startEvent(self, eventName, metaData):
+ return self._server.workflowmgr.handleEvent(eventName, metaData)
+ #Hashtable paginateWorkflowInstances(int pageNum)
+ def paginateWorkflowInstances(self, pageNum):
+ return
self._server.workflowmgr.paginateWorkflowInstances(pageNum)
+ #Hashtable paginateWorkflowInstances(int pageNum, String
status)(self, workflowInstId)
+ def paginateWorkflowInstances(self, pageNum, status):
+ return
self._server.workflowmgr.paginateWorkflowInstances(pageNum, status)
+ #boolean pauseWorkflowInstance(String workflowInstId)
+ def pauseWorkflowInstance(self, workflowInstId):
+ return
self._server.workflowmgr.pauseWorkflowInstance(workflowInstId)
+ #boolean resumeWorkflowInstance(String workflowInstId)
+ def resumeWorkflowInstance(self, workflowInstId):
+ return
self._server.workflowmgr.resumeWorkflowInstance(workflowInstId)
+ #boolean setWorkflowInstanceCurrentTaskEndDateTime(String
wInstId, String endDateTimeIsoStr)
+ def setWorkflowInstanceCurrentTaskEndDateTime(self, workflowInstId,
endDateTimeIsoStr):
+ return
self._server.workflowmgr.setWorkflowInstanceCurrentTaskEndDateTime(workflowInstId,
endDateTimeIsoStr)
+ #boolean setWorkflowInstanceCurrentTaskStartDateTime(String
wInstId, String startDateTimeIsoStr)
+ def setWorkflowInstanceCurrentTaskStartDateTime(self, workflowInstId,
startDateTimeIsoStr):
+ return
self._server.workflowmgr.setWorkflowInstanceCurrentTaskStartDateTime(workflowInstId,
startDateTimeIsoStr)
+ #boolean stopWorkflowInstance(String workflowInstId)
+ def stopWorkflowInstance(self, workflowInstId):
+ return
self._server.workflowmgr.stopWorkflowInstance(workflowInstId)
+ #boolean updateMetadataForWorkflow(String workflowInstId,
Hashtable metadata)
+ def updateMetadataForWorkflow(self, workflowInstId, metadata):
+ return
self._server.workflowmgr.updateMetadataForWorkflow(workflowInstId, metadata)
+ #boolean updateWorkflowInstance(Hashtable workflowInst)
+ def updateWorkflowInstance(workflowInst):
+ return
self._server.workflowmgr.updateWorkflowInstance(workflowInst)
+ #boolean updateWorkflowInstanceStatus(String workflowInstanceId,
String status)
+ def updateWorkflowInstanceStatus(self, workflowInstId, status):
+ return
self._server.workflowmgr.updateWorkflowInstanceStatus(workflowInstId, status)
+
+
+
+def main():
+ # create instance
+ oodt = OODTWorkFlowWrapper("http://localhost:9200";)
+ # get event info
+ events = oodt.getEventNames()
+ # create metadata object to invoke an event
+ met = MetaData()
+ met.addMetaData("hello", "world")
+ # print available events
+ print 'available events:', events
+
+ # oodt.startEvent(events[0], met.toXmlRpc())
+
+if __name__ == '__main__':
+ main()
