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
