def put(self, stream, cmd):
if len(self.q) < self.max_size:<EOL><INDENT>if stream['<STR_LIT:id>'] in self.q:<EOL><INDENT>raise QueueDuplicate<EOL><DEDENT>p = self.call(stream, cmd)<EOL>self.q[stream['<STR_LIT:id>']] = p<EOL><DEDENT>else:<EOL><INDENT>raise QueueFull<EOL><DEDENT>
Spawn a new background process