@retry(<NUM_LIT:9>, Exception, <NUM_LIT>, '<STR_LIT>')<EOL><INDENT>def _put_on_pipe(self, to_put):<DEDENT>
self.acquire_lock()<EOL>self._send_chunks(to_put)<EOL>self.release_lock()<EOL>
Puts data on queue