Return-Path: X-Original-To: apmail-airavata-dev-archive@www.apache.org Delivered-To: apmail-airavata-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 00D7410365 for ; Fri, 29 Nov 2013 03:18:14 +0000 (UTC) Received: (qmail 68258 invoked by uid 500); 29 Nov 2013 03:18:11 -0000 Delivered-To: apmail-airavata-dev-archive@airavata.apache.org Received: (qmail 68147 invoked by uid 500); 29 Nov 2013 03:18:07 -0000 Mailing-List: contact dev-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list dev@airavata.apache.org Received: (qmail 68140 invoked by uid 99); 29 Nov 2013 03:18:06 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 29 Nov 2013 03:18:06 +0000 X-ASF-Spam-Status: No, hits=1.8 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,WEIRD_PORT X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of nipuni880917@gmail.com designates 209.85.212.179 as permitted sender) Received: from [209.85.212.179] (HELO mail-wi0-f179.google.com) (209.85.212.179) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 29 Nov 2013 03:18:00 +0000 Received: by mail-wi0-f179.google.com with SMTP id ey16so1527731wid.0 for ; Thu, 28 Nov 2013 19:17:39 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=SeUJEZEEnPr//gE2y3HgvSAfVyVByBBjtYcPqpZKJhM=; b=iD7zCz3TLzYkZyx43bbhiudA0oRWqxWt8wF/EXloO5lrqbNQZVuJ3fQ5neGD/+jv3Q PDTqZEAM/gqmyXkjbXV5kjcoGD7pmAvM5eAa/qGNr/RMfES0pCUWwUrgPMdovzEdMsuG PIVR9CxMcXStgiDt9OQwi0re9HDK1lOpi43DsARbYrKSbBkAsg8jM9Ms1DvONG2NajLN zOd5y5OfcCsirtpQO1wKcYEOgEj58GjhtGakkXg0YNmgbyCrh9zkVWo6z5vUuj+AfzZQ MlrqJ2tr7A42bw1YokXjOJAMA5FrlNUPDD0Ngrz2eZEoBhLTu57h0sQPXBvJIw+tkL51 FJ6w== MIME-Version: 1.0 X-Received: by 10.194.243.170 with SMTP id wz10mr37386wjc.74.1385695059403; Thu, 28 Nov 2013 19:17:39 -0800 (PST) Received: by 10.216.4.3 with HTTP; Thu, 28 Nov 2013 19:17:39 -0800 (PST) In-Reply-To: References: <5004AF3F-BFC0-4845-A175-EC00FA133B29@gmail.com> Date: Fri, 29 Nov 2013 08:47:39 +0530 Message-ID: Subject: Re: Workflow monitoring in Client API From: Nipuni Piyabasi Perera To: Airavata Dev Content-Type: multipart/alternative; boundary=089e0149411ac8695504ec484511 X-Virus-Checked: Checked by ClamAV on apache.org --089e0149411ac8695504ec484511 Content-Type: text/plain; charset=ISO-8859-1 Hi, I want to run a workflow in a WPS server through Airavata. We have integrated WPS server with Airavata server. We testing executing deployed workflow through WPS client. (We have created a WPS client and wrapped it using a script so that it can be imported as a component via Airavata) Thanks, Nipuni On Thu, Nov 28, 2013 at 9:13 PM, Saminda Wijeratne wrote: > 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 < > nipuni880917@gmail.com> 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 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 < >>> nipuni880917@gmail.com> wrote: >>> >>>> Hi, >>>> >>>> Yes it is working after calling >>>> >>>> airavataAPI.getExecutionManager().waitForExperimentTermination(...) >>>> >>>> >>>> >>>> >>>> >>>> >>>> Thanks, >>>> Nipuni >>>> >>>> >>>> >>>> >>>> On Sat, Nov 16, 2013 at 3:54 AM, Saminda Wijeratne 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 < >>>>> 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 >>>>>> >>>>> >>>>> >>>> >>>> >>>> -- >>>> 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 --089e0149411ac8695504ec484511 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi,

I want to run a workflow in a WPS se= rver through=20 Airavata. We have integrated WPS server with Airavata server. We testing executing deployed workflow through WPS client. (We have created a WPS cli= ent and wrapped it using a script so that it can be imported as a component= via Airavata)

Thanks,<= br>
Nipuni


On Thu, Nov 28, 2013 at 9:13 PM, Saminda Wijeratne <samindaw@gmail.com> wrote:
What did you exactly mean by a workflow in another server?= Did you have another Airavata server running with the workflow which you i= ntended to run?


On Thu, Nov 28, 2013 at 8:42 AM, Nipuni Piyabasi Perera &= lt;nipuni880917= @gmail.com> wrote:
Hi,

I could receive generated events dur= ing an=20 experiment execution in workflows created with=A0 wslds [1]. But it does=20 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?.=A0
[1] http://gw8.quarry.iu.= teragrid.org:8090/axis2-samples/services/SimpleMathService?wsdl =


Thanks,
Nipuni


On Sat, Nov 16, 2013 at 6:34 A= M, Saminda Wijeratne <samindaw@gmail.com> wrote:
My guess is that your clien= t side application (the main thread) terminates before the listener gets an= y messages from the server. Thus you don't see any output.


On Fri, Nov 15, 2013 at 7:59 PM, Nipuni Piyabasi= Perera <nipuni880917@gmail.com> wrote:
Hi,

Yes it is working after calling
= 
airavataAPI.getExecutionManager().waitForExperimentTermination(...)








Thanks,
Nipuni


On Sat, Nov 16, 2013 at 3:54 AM, Saminda Wijerat= ne <samindaw@gmail.com> wrote:
hmmm...

Can you see the experiment getting executed at the backend server?
<= br>
Can you also please call the following after the "...startMonito= ring()"
airavataAPI.getExecutionManager().waitForExperimentTer=
mination(...)



On Thu, Nov 14, 2013 at 11:14 PM, Nipuni Piyabasi Perera <= span dir=3D"ltr"><nipuni880917@gmail.com> wrote:
Yes. I does call

experimentMonitor.startMonitoring();

Thanks,


Nipuni



On Fri, Nov 15, 2013 at 9:3= 7 AM, Saminda Wijeratne <samindaw@gmail.com> wrote:
Does your code call
experimentMonitor.startMonitoring(); ???
= EventDataRepository object (and EventData) is managed inside the monitor ob= ject returned by the airavataAPI.getExecutionManager().getExperimentMonitor(...) function. And the monitor object will call the notify method in= the listener with those objects as parameters

O= n Thu, Nov 14, 2013 at 11:02 PM, Nipuni Piyabasi Perera &= lt;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 Pe= rera <nipuni880917@gmail.com> wrote:
Hi,=

Given workflow name and its inputs, I am receiving the experiment i= d with,

=A0= =A0=A0=A0=A0=A0=A0=A0=A0 String experimentId =3DairavataAPI.getExecutionMan= ager().runExperiment(workflowId, workflowInputs);

Then start monitoring here,

=A0=A0=A0=A0=A0=A0= =A0=A0=A0 MonitorListener monitorListener =3D new MonitorListener();
=A0= =A0=A0=A0=A0=A0=A0=A0=A0 Monitor experimentMonitor =3D airavataAPI.getExecu= tionManager().getExperimentMonitor(experimentId,
=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0=A0 monitorListener);
=A0=A0= =A0=A0=A0=A0=A0=A0=A0 log.inf= o("Started the Workflow monitor");

This code executes and prints the log message. But this does not print log=20 messages inside notify() method in "MonitorListner" class

= 
pub=
lic void notify(EventDataRepository eventDataRepo, EventData eventData) {
        log.info("Ex=
perimentID: " + eventData.getExperimentID());
        log.info("Me=
ssage: " + eventData.getMessage());
    }

On Fri, Nov 15, 2013 at 8:25 AM, Saminda Wijera= tne <samindaw@gmail.com> wrote:
hi Nipuni,
When the experiment starts the events are generated a= t the server side regardless whether anyone starts monitoring or not. By st= artMonitoring() at the client side it will subscribe to those generated eve= nts. 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?
<= br>
On Thu, Nov 14, 2013 at 9:14 PM, Nipuni P= iyabasi Perera <nipuni880917@gmail.com> wrote:
Hi,

To monitor workflow execution, I have=20 registered a listener with monitor as in the sample code here[1]. My=20 Listener class [2] should call notify() method if there is any events=20 generated while workflow execution. But it does not call notify method.=20 After "startMonitoring()" is called does it automatically generat= e=20 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/airavat= a/client/samples/MonitorWorkflow.java

[2] https://svn= .apache.org/repos/asf/airavata/tags/airavata-0.7/samples/airavata-client/wo= rkflow-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 l= ook into following class.=A0


Thanks
Raminder=
=A0
On Aug 7, 2013, at 1:2= 2 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 "Moni= tor" can be accessed via=A0 "ExecutionManager" [1], and it p= rovides 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/airavat= a-0.7/samples/airavata-client/workflow-run/src/main/java/org/apache/airavat= a/client/samples/MonitorWorkflow.java

Thanks,
Nipuni
--
Nipuni Piyabasi Per= era
Undergraduate
Department of Computer Scien= ce And Engineering
University of Moratuwa
Sri Lanka



--
Nipuni Piyabasi PereraUndergraduate
Department of Computer Science And Engineer= ing
University of Moratuwa
Sri Lanka




--
= Nipuni Piyabasi Perera
Undergraduate
Departmen= t of Computer Science And Engineering
University of Moratuwa
Sri Lanka



--
= Nipuni Piyabasi Perera
Undergraduate
Departmen= t of Computer Science And Engineering
University of Moratuwa
Sri Lanka




--
Nipuni Piyab= asi Perera
Undergraduate
Department of Compute= r Science And Engineering
University of Moratuwa
Sri Lanka




--
= Nipuni Piyabasi Perera
Undergraduate
Departmen= t of Computer Science And Engineering
University of Moratuwa
Sri Lanka




--
= Nipuni Piyabasi Perera
Undergraduate
Departmen= t of Computer Science And Engineering
University of Moratuwa
Sri Lanka




--
= Nipuni Piyabasi Perera
Undergraduate
Departmen= t of Computer Science And Engineering
University of Moratuwa
Sri Lanka
--089e0149411ac8695504ec484511--