What did you exactly mean by a workflow in another server? Did you have another Airavata server running with the workflow which you intended to run?
On Thu, Nov 28, 2013 at 8:42 AM, Nipuni Piyabasi Perera < [email protected]> wrote: > Hi, > > I could receive generated events during an experiment execution in > workflows created with wslds [1]. But it does not give events when I tried > to execute a workflow in another sever. Do I need to set any other > configuration than running a simple workflow?. > > [1] > http://gw8.quarry.iu.teragrid.org:8090/axis2-samples/services/SimpleMathService?wsdl > > > Thanks, > Nipuni > > > On Sat, Nov 16, 2013 at 6:34 AM, Saminda Wijeratne <[email protected]>wrote: > >> My guess is that your client side application (the main thread) >> terminates before the listener gets any messages from the server. Thus you >> don't see any output. >> >> >> On Fri, Nov 15, 2013 at 7:59 PM, Nipuni Piyabasi Perera < >> [email protected]> wrote: >> >>> Hi, >>> >>> Yes it is working after calling >>> >>> airavataAPI.getExecutionManager().waitForExperimentTermination(...) >>> >>> >>> >>> >>> >>> Thanks, >>> Nipuni >>> >>> >>> >>> >>> On Sat, Nov 16, 2013 at 3:54 AM, Saminda Wijeratne >>> <[email protected]>wrote: >>> >>>> hmmm... >>>> >>>> Can you see the experiment getting executed at the backend server? >>>> >>>> Can you also please call the following after the "...startMonitoring()" >>>> >>>> airavataAPI.getExecutionManager().waitForExperimentTermination(...) >>>> >>>> >>>> >>>> >>>> >>>> On Thu, Nov 14, 2013 at 11:14 PM, Nipuni Piyabasi Perera < >>>> [email protected]> wrote: >>>> >>>>> Yes. I does call >>>>> >>>>> experimentMonitor.startMonitoring(); >>>>> >>>>> >>>>> >>>>> >>>>> >>>>> >>>>> >>>>> Thanks, >>>>> >>>>> Nipuni >>>>> >>>>> >>>>> >>>>> >>>>> On Fri, Nov 15, 2013 at 9:37 AM, Saminda Wijeratne <[email protected] >>>>> > wrote: >>>>> >>>>>> Does your code call >>>>>> >>>>>> experimentMonitor.startMonitoring(); ??? >>>>>> >>>>>> EventDataRepository object (and EventData) is managed inside the >>>>>> monitor object returned by the >>>>>> airavataAPI.getExecutionManager().getExperimentMonitor(...) >>>>>> function. And the monitor object will call the notify method in the >>>>>> listener with those objects as parameters >>>>>> >>>>>> On Thu, Nov 14, 2013 at 11:02 PM, Nipuni Piyabasi Perera < >>>>>> [email protected]> wrote: >>>>>> >>>>>>> Hi, >>>>>>> >>>>>>> Inside MonitorListner class, how does it set up the >>>>>>> EventDataRepository and EventData parameters that are passed into >>>>>>> notify() >>>>>>> mthod? >>>>>>> >>>>>>> Thanks, >>>>>>> Nipuni >>>>>>> >>>>>>> >>>>>>> >>>>>>> On Fri, Nov 15, 2013 at 8:51 AM, Nipuni Piyabasi Perera < >>>>>>> [email protected]> wrote: >>>>>>> >>>>>>>> Hi, >>>>>>>> >>>>>>>> Given workflow name and its inputs, I am receiving the experiment >>>>>>>> id with, >>>>>>>> >>>>>>>> String experimentId >>>>>>>> =airavataAPI.getExecutionManager().runExperiment(workflowId, >>>>>>>> workflowInputs); >>>>>>>> >>>>>>>> Then start monitoring here, >>>>>>>> >>>>>>>> MonitorListener monitorListener = new MonitorListener(); >>>>>>>> Monitor experimentMonitor = >>>>>>>> airavataAPI.getExecutionManager().getExperimentMonitor(experimentId, >>>>>>>> monitorListener); >>>>>>>> log.info("Started the Workflow monitor"); >>>>>>>> >>>>>>>> This code executes and prints the log message. But this does not >>>>>>>> print log messages inside notify() method in "MonitorListner" class >>>>>>>> >>>>>>>> public void notify(EventDataRepository eventDataRepo, EventData >>>>>>>> eventData) { >>>>>>>> log.info("ExperimentID: " + eventData.getExperimentID()); >>>>>>>> log.info("Message: " + eventData.getMessage()); >>>>>>>> } >>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> On Fri, Nov 15, 2013 at 8:25 AM, Saminda Wijeratne < >>>>>>>> [email protected]> wrote: >>>>>>>> >>>>>>>>> hi Nipuni, >>>>>>>>> When the experiment starts the events are generated at the server >>>>>>>>> side regardless whether anyone starts monitoring or not. By >>>>>>>>> startMonitoring() at the client side it will subscribe to those >>>>>>>>> generated >>>>>>>>> events. Server will send the client a copy of those events. >>>>>>>>> >>>>>>>>> How are you passing your listener to the API? Can you illustrate >>>>>>>>> what you are doing in code? >>>>>>>>> >>>>>>>>> >>>>>>>>> On Thu, Nov 14, 2013 at 9:14 PM, Nipuni Piyabasi Perera < >>>>>>>>> [email protected]> wrote: >>>>>>>>> >>>>>>>>>> Hi, >>>>>>>>>> >>>>>>>>>> To monitor workflow execution, I have registered a listener with >>>>>>>>>> monitor as in the sample code here[1]. My Listener class [2] should >>>>>>>>>> call >>>>>>>>>> notify() method if there is any events generated while workflow >>>>>>>>>> execution. >>>>>>>>>> But it does not call notify method. After "startMonitoring()" is >>>>>>>>>> called >>>>>>>>>> does it automatically generate events?. >>>>>>>>>> >>>>>>>>>> I am using Airavata 0.7 release. >>>>>>>>>> >>>>>>>>>> [1] >>>>>>>>>> https://svn.apache.org/repos/asf/airavata/trunk/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorWorkflow.java >>>>>>>>>> >>>>>>>>>> >>>>>>>>>> [2] >>>>>>>>>> https://svn.apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorListener.java >>>>>>>>>> >>>>>>>>>> Thanks, >>>>>>>>>> Nipuni. >>>>>>>>>> >>>>>>>>>> >>>>>>>>>> On Wed, Aug 7, 2013 at 7:07 PM, Raminder Singh < >>>>>>>>>> [email protected]> wrote: >>>>>>>>>> >>>>>>>>>>> Thanks for your interest in Airavata. You need not to poll. You >>>>>>>>>>> can register a listener with your monitor to get constant updates. >>>>>>>>>>> Please >>>>>>>>>>> look into following class. >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> https://svn.apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorListener.java >>>>>>>>>>> >>>>>>>>>>> Thanks >>>>>>>>>>> Raminder >>>>>>>>>>> >>>>>>>>>>> On Aug 7, 2013, at 1:22 AM, Nipuni Piyabasi Perera < >>>>>>>>>>> [email protected]> wrote: >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> Hi, >>>>>>>>>>> >>>>>>>>>>> I am implementing Airavata client API and I need to monitor >>>>>>>>>>> running workflow status. I have noticed that a "Monitor" can be >>>>>>>>>>> accessed >>>>>>>>>>> via "ExecutionManager" [1], and it provides startMonitoring() and >>>>>>>>>>> stopMonitoring() methods. >>>>>>>>>>> I need to clarify whether it allows to display workflow status >>>>>>>>>>> continuously or does it need poll to view status. >>>>>>>>>>> >>>>>>>>>>> [1] >>>>>>>>>>> https://svn.apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavata/client/samples/MonitorWorkflow.java >>>>>>>>>>> >>>>>>>>>>> Thanks, >>>>>>>>>>> Nipuni >>>>>>>>>>> -- >>>>>>>>>>> Nipuni Piyabasi Perera >>>>>>>>>>> Undergraduate >>>>>>>>>>> Department of Computer Science And Engineering >>>>>>>>>>> University of Moratuwa >>>>>>>>>>> Sri Lanka >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>>> >>>>>>>>>> >>>>>>>>>> >>>>>>>>>> -- >>>>>>>>>> Nipuni Piyabasi Perera >>>>>>>>>> Undergraduate >>>>>>>>>> Department of Computer Science And Engineering >>>>>>>>>> University of Moratuwa >>>>>>>>>> Sri Lanka >>>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>> >>>>>>>> >>>>>>>> -- >>>>>>>> Nipuni Piyabasi Perera >>>>>>>> Undergraduate >>>>>>>> Department of Computer Science And Engineering >>>>>>>> University of Moratuwa >>>>>>>> Sri Lanka >>>>>>>> >>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> Nipuni Piyabasi Perera >>>>>>> Undergraduate >>>>>>> Department of Computer Science And Engineering >>>>>>> University of Moratuwa >>>>>>> Sri Lanka >>>>>>> >>>>>> >>>>>> >>>>> >>>>> >>>>> -- >>>>> Nipuni Piyabasi Perera >>>>> Undergraduate >>>>> Department of Computer Science And Engineering >>>>> University of Moratuwa >>>>> Sri Lanka >>>>> >>>> >>>> >>> >>> >>> -- >>> Nipuni Piyabasi Perera >>> Undergraduate >>> Department of Computer Science And Engineering >>> University of Moratuwa >>> Sri Lanka >>> >> >> > > > -- > Nipuni Piyabasi Perera > Undergraduate > Department of Computer Science And Engineering > University of Moratuwa > Sri Lanka >
