airavata-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nipuni Piyabasi Perera <nipuni880...@gmail.com>
Subject Re: Workflow monitoring in Client API
Date Fri, 15 Nov 2013 04:02:38 GMT
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

Mime
View raw message