Commit 723a37db authored by Georgios Gousios's avatar Georgios Gousios
Browse files

waitpid() accepts two arguments by default

parent 5b753911
......@@ -243,10 +243,9 @@ def main():
# Wait for all children process to die, one by one
for pid in children:
try:
os.waitpid(pid)
except Exception as e:
logger.error("Error waiting for child %d: %s"%(pid, e.message))
raise
os.waitpid(pid, 0)
except Exception:
pass
if __name__ == "__main__":
......
......@@ -83,7 +83,8 @@ def send_email(message):
try:
msg = json.loads(message.body)
email_send.send(frm=msg['frm'], to = msg[to], body=msg['body'], subject=msg['subject'])
email_send.send(frm=msg['frm'], to = msg['to'],
body=msg['body'], subject=msg['subject'])
message.channel.basic_ack(message.delivery_tag)
except KeyError:
_logger.error("Malformed incoming JSON, missing attributes: %s",
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment