Return-Path: X-Original-To: apmail-oodt-dev-archive@www.apache.org Delivered-To: apmail-oodt-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 80265FB46 for ; Tue, 2 Apr 2013 15:32:35 +0000 (UTC) Received: (qmail 6477 invoked by uid 500); 2 Apr 2013 15:32:35 -0000 Delivered-To: apmail-oodt-dev-archive@oodt.apache.org Received: (qmail 6238 invoked by uid 500); 2 Apr 2013 15:32:32 -0000 Mailing-List: contact user-help@oodt.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@oodt.apache.org Delivered-To: mailing list user@oodt.apache.org Received: (qmail 6197 invoked by uid 99); 2 Apr 2013 15:32:31 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Apr 2013 15:32:31 +0000 X-ASF-Spam-Status: No, hits=-2.3 required=5.0 tests=RCVD_IN_DNSWL_MED,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: local policy) Received: from [128.149.139.106] (HELO mail.jpl.nasa.gov) (128.149.139.106) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Apr 2013 15:32:26 +0000 Received: from mail.jpl.nasa.gov (ap-ehub-sp01.jpl.nasa.gov [128.149.137.148]) by smtp.jpl.nasa.gov (Sentrion-MTA-4.3.1/Sentrion-MTA-4.3.1) with ESMTP id r32FW4G4011693 (using TLSv1/SSLv3 with cipher AES128-SHA (128 bits) verified NO) for ; Tue, 2 Apr 2013 08:32:05 -0700 Received: from AP-EMBX-SP20.RES.AD.JPL ([169.254.8.22]) by ap-ehub-sp01.RES.AD.JPL ([169.254.3.100]) with mapi id 14.02.0342.003; Tue, 2 Apr 2013 08:32:04 -0700 From: "Cayanan, Michael D (388J)" To: "user@oodt.apache.org" Subject: Re: Workflow Questions Thread-Topic: Workflow Questions Thread-Index: AQHOL0/sOzPHOyrG30mZ79CnA5ZY8ZjC2McAgAA3CgA= Date: Tue, 2 Apr 2013 15:32:03 +0000 Message-ID: In-Reply-To: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: user-agent: Microsoft-MacOutlook/14.3.2.130206 x-originating-ip: [128.149.137.113] Content-Type: text/plain; charset="us-ascii" Content-ID: Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-Source-Sender: michael.d.cayanan@jpl.nasa.gov X-AUTH: Authorized X-Virus-Checked: Checked by ClamAV on apache.org Hey Chris, I suppose I could. For some reason I didn't think that it was possible to submit a job to the Resource Manager other than through the Workflow. In my case, I'm using a listener to pull files out of the RabbitMQ. After I pull a file out of the queue, I'd like to submit a job to the Resource Manager to trigger a Workflow Event. How would one submit a job this way? Under the Resource Manager trunk, in src/main/resources/examples/jobs, I see 2 xml files that appear to be config files. Do I need to make use of these to do what I want to do? Also, I know that the Resource Manager has it's own queue where it places jobs when all of its compute nodes are full. In my case (this is for Costin's pipeline BTW), I don't want jobs being placed in the Resource Manager queue. I would like for them to remain in the Rabbit Queue. Is the Resource Manager's "getNodeLoad()" method the best way to check if a node is full before submitting a job? Thanks in advance for your help! -Mike On 4/1/13 10:15 PM, "Mattmann, Chris A (388J)" wrote: >Hey Mike, > >I'll bite, can't you use the Resource Manager and its queues/nodes to do >this? > >Cheers, >Chris > >++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ >Chris Mattmann, Ph.D. >Senior Computer Scientist >NASA Jet Propulsion Laboratory Pasadena, CA 91109 USA >Office: 171-266B, Mailstop: 171-246 >Email: chris.a.mattmann@nasa.gov >WWW: http://sunset.usc.edu/~mattmann/ >++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ >Adjunct Assistant Professor, Computer Science Department >University of Southern California, Los Angeles, CA 90089 USA >++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ > > > > > > >-----Original Message----- >From: , "Michael D (388J)" >Reply-To: "user@oodt.apache.org" >Date: Monday, April 1, 2013 8:11 PM >To: "user@oodt.apache.org" >Subject: Workflow Questions > >>Hi all, >> >> >>I'm trying to see if anyone knows of a cool, easy to use "Resource >>Manager" that can control the amount of Workflows running concurrently on >>a node. Basically, my set up is like this: >> >> >>- I have a Workflow Manager Server configured to run at most 10 Workflow >>Events concurrently. >>- I have a bunch of files sitting on a RabbitMQ queue. >>- I have a listener that is continually monitoring this particular queue. >>As soon as it sees a file in this queue, it will trigger a Workflow >>event. >> >> >>Under this scenario, normally if I have 30 files in the RabbitMQ, my >>listener will trigger 30 Workflow events. However, the Workflow Server >>would put 20 of these events in its repository queue while the other 10 >>are running. >> >> >>What I want some "Resource Manager" component to do is just run the 10 >>Workflow events only and have the other 20 sitting in the RabbitMQ. As >>soon as 1 event has finished, then trigger another workflow event to keep >>the number of concurrent workflows running >> at 10. >>Eventually, we will want this "Resource Manager" component to be able to >>point to another node, node 2, where it can decide to trigger another set >>of 10 Workflow events while node 1 is still running it's 10 Workflow >>events. >> >> >>Hope this makes sense. Any helpful tips would be much appreciated. >> >> >>Thanks, >>Mike >