Re: multiprocessing in a while loop?

X-Received	by 10.68.230.193 with SMTP id ta1mr13702901pbc.6.1403911653025; Fri, 27 Jun 2014 16:27:33 -0700 (PDT)
X-Received	by 10.50.25.168 with SMTP id d8mr132585igg.1.1403911652885; Fri, 27 Jun 2014 16:27:32 -0700 (PDT)
Path	csiph.com!v102.xanadu-bbs.net!xanadu-bbs.net!news.glorb.com!uq10no14337819igb.0!news-out.google.com!bp9ni0igb.0!nntp.google.com!uq10no14337798igb.0!postnews.google.com!glegroupsg2000goo.googlegroups.com!not-for-mail
Newsgroups	comp.lang.python
Date	Fri, 27 Jun 2014 16:27:32 -0700 (PDT)
In-Reply-To	<mailman.9704.1399402109.18130.python-list@python.org>
Complaints-To	groups-abuse@google.com
Injection-Info	glegroupsg2000goo.googlegroups.com; posting-host=67.188.68.37; posting-account=e3JAwwoAAACDPfN3faj8APXoNAumAHl5
NNTP-Posting-Host	67.188.68.37
References	<mailman.9704.1399402109.18130.python-list@python.org>
User-Agent	G2/1.0
MIME-Version	1.0
Message-ID	<95320b71-37bb-4e53-a28c-ae9e87772f7f@googlegroups.com> (permalink)
Subject	Re: multiprocessing in a while loop?
From	Jesse Adam <jaahush@gmail.com>
Injection-Date	Fri, 27 Jun 2014 23:27:32 +0000
Content-Type	text/plain; charset=ISO-8859-1
Xref	csiph.com comp.lang.python:73679

Show key headers only | View raw

Could you post 
a) what the output looks like now (sans the logging part)
b) what output do you expect


In any event, this routine does not look right to me:

def consume_queue(queue_name):
  conn = boto.connect_sqs()
  q = conn.get_queue(queue_name)
  m = q.read()
  while m is not None:
    yield m
    q.delete_message(m)
    logger.debug('message deleted')
    m = q.read()

Back to comp.lang.python | Previous | Next — Previous in thread | Find similar | Unroll thread

Thread

multiprocessing in a while loop? Johan Llewellyn <johan.llewellyn@yahoo.com> - 2014-05-06 11:45 -0700
  Re: multiprocessing in a while loop? Jesse Adam <jaahush@gmail.com> - 2014-06-27 16:27 -0700

csiph-web