airavata-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saminda Wijeratne <samin...@gmail.com>
Subject Re: Workflow monitoring in Client API
Date Fri, 15 Nov 2013 22:24:50 GMT
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 <
nipuni880917@gmail.com> wrote:

> Yes. I does call
>
> experimentMonitor.startMonitoring();
>
> Thanks,
>
> Nipuni
>
>
>
>
> On Fri, Nov 15, 2013 at 9:37 AM, Saminda Wijeratne <samindaw@gmail.com>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 <
>> nipuni880917@gmail.com> 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 <
>>> nipuni880917@gmail.com> 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 <samindaw@gmail.com>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 <
>>>>> nipuni880917@gmail.com> 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 <
>>>>>> raminderjsingh@gmail.com> 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 <
>>>>>>> nipuni880917@gmail.com> 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
>

Mime
View raw message