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:14:41 GMT
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