(cls, address, authkey)
| 3575 | |
| 3576 | @classmethod |
| 3577 | def _putter(cls, address, authkey): |
| 3578 | manager = QueueManager( |
| 3579 | address=address, authkey=authkey, serializer=SERIALIZER, |
| 3580 | shutdown_timeout=SHUTDOWN_TIMEOUT) |
| 3581 | manager.connect() |
| 3582 | queue = manager.get_queue() |
| 3583 | queue.put('hello world') |
| 3584 | |
| 3585 | @warnings_helper.ignore_fork_in_thread_deprecation_warnings() |
| 3586 | @support.skip_if_sanitizer("TSan: leaks threads", thread=True) |
nothing calls this directly
no test coverage detected