mitogen-hq / mitogen

Distributed self-replicating programs in Python
https://mitogen.networkgenomics.com/
BSD 3-Clause "New" or "Revised" License
2.32k stars 197 forks source link

RFE: Support shell/bash based modules #889

Closed opoplawski closed 2 years ago

opoplawski commented 2 years ago

Please drag-drop large logs as text file attachments.

Feel free to write an issue in your preferred format, however if in doubt, use the following checklist as a guide for what to include.

I think the issue is that mitogen just does not support modules written in bash. Is that right?

TASK [Configure logging] *************************************************************************
task path: /export/home/orion-admin/ansible-boulder/playbooks/openwrt-test.yml:7
[task 1146768] 12:43:45.470834 D ansible_mitogen.affinity: CPU mask for WorkerProcess: 0x000020
redirecting (type: lookup) ansible.builtin.dig to community.general.dig
[task 1146768] 12:43:45.594604 D ansible_mitogen.process: will use multiplexer 0 (/tmp/mitogen_unix_j137zuo4.sock) to connect to "nwra-ap2.nwra.com"
[task 1146768] 12:43:45.594805 D mitogen.unix: client: connecting to /tmp/mitogen_unix_j137zuo4.sock
[mux  1146622] 12:43:45.595093 D mitogen.io: EpollPoller: POLLIN: 10
[task 1146768] 12:43:45.595419 D mitogen.unix: client: local ID is 1009, remote is 0
[mux  1146622] 12:43:45.595476 D mitogen.unix: listener: accepted connection from PID 1146768: unix_client.1146768
[mux  1146622] 12:43:45.595618 D mitogen.io: Broker(04a8).start_receive(<Stream unix_client.1146768 #5080>)
[task 1146768] 12:43:45.595612 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method Router._on_del_route of Router(Broker(3e48))>, 104, True)
[mux  1146622] 12:43:45.595757 D mitogen.io: Waker(fd=6/8).defer() [immediate]
[task 1146768] 12:43:45.595767 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method IdAllocator.on_allocate_id of IdAllocator(Router(Broker(3e48)))>, 105, True)
[mux  1146622] 12:43:45.595898 D mitogen.io: EpollPoller.start_receive(75, (<Side of unix_client.1146768 fd 75>, <bound method Stream.on_receive of <Stream unix_client.1146768 #5080>>))
[task 1146768] 12:43:45.595953 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method ModuleResponder._on_get_module of ModuleResponder>, 100, True)
[mux  1146622] 12:43:45.596039 D mitogen.io: EpollPoller._control(75)
[task 1146768] 12:43:45.596092 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method LogForwarder._on_forward_log of LogForwarder(Router(Broker(3e48)))>, 102, True)
[mux  1146622] 12:43:45.596207 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:45.596278 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method RouteMonitor._on_add_route of RouteMonitor()>, 103, True)
[mux  1146622] 12:43:45.596353 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:45.596476 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method RouteMonitor._on_del_route of RouteMonitor()>, 104, True)
[task 1146768] 12:43:45.596612 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method Router._on_detaching of Router(Broker(3e48))>, 109, True)
[task 1146768] 12:43:45.596847 D mitogen.io: Broker(3e48).start_receive(<Stream unix_listener.1146622 #dd30>)
[task 1146768] 12:43:45.596997 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:45.597333 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method Receiver._on_receive of Receiver(Router(Broker(3e48)), None)>, 1000, False)
[task 1146768] 12:43:45.597487 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:45.597688 D mitogen.io: Receiver(Router(Broker(3e48)), 1000).get(timeout=None, block=True)
[task 1146768] 12:43:45.597823 D mitogen.io: Latch(0x7fa13b00c940, size=0, t='MainThread').get(timeout=None, block=True)
[task 1146768] 12:43:45.598063 D mitogen.io: Latch(0x7fa13b00c940, size=0, t='MainThread')._get_sleep(timeout=None, block=True, fd=13/14)
[task 1146768] 12:43:45.598220 D mitogen.io: PollPoller.poll(None)
[task 1146768] 12:43:45.598364 D mitogen.io: Poller: POLLIN for 10
[task 1146768] 12:43:45.598521 D mitogen.io: Waker(fd=10/11).on_receive()
[task 1146768] 12:43:45.599323 D mitogen.io: Router(Broker(3e48))._async_route(Message(0, 1009, 1009, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693), None)
[task 1146768] 12:43:45.599471 D mitogen.io: MitogenProtocol(unix_listener.1146622)._send(Message(0, 1009, 1009, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693))
[task 1146768] 12:43:45.599643 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[mux  1146622] 12:43:45.599651 D mitogen.io: EpollPoller: POLLIN: 75
[task 1146768] 12:43:45.599776 D mitogen.io: Poller.poll(None)
[mux  1146622] 12:43:45.599831 D mitogen.io: MitogenProtocol(unix_client.1146768).on_receive()
[task 1146768] 12:43:45.599911 D mitogen.io: Poller: POLLIN for 10
[mux  1146622] 12:43:45.600001 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 1009, 1009, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693), <Stream unix_client.1146768 #5080>)
[task 1146768] 12:43:45.600103 D mitogen.io: Waker(fd=10/11).on_receive()
[mux  1146622] 12:43:45.600206 D mitogen.io: Receiver(Router(Broker(04a8)), 110)._on_receive(Message(0, 1009, 0, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693))
[task 1146768] 12:43:45.600292 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[mux  1146622] 12:43:45.600350 D mitogen.io: Latch(0x7fa13b990a20, size=0, t='mitogen.broker').put(Message(0, 1009, 0, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693))
[task 1146768] 12:43:45.600420 D mitogen.io: Poller.poll(None)
[mux  1146622] 12:43:45.600498 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.broker').put(Receiver(Router(Broker(04a8)), 110))
[mux  1146622] 12:43:45.600639 D mitogen.io: Latch(0x7fa13b990ac8, size=1, t='mitogen.broker').put() -> waking wfd=68
[mux  1146622] 12:43:45.600799 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:45.600930 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:45.601079 D mitogen.io: PollPoller: POLLIN|POLLHUP for 67
[mux  1146622] 12:43:45.601339 D mitogen.io: Latch(0x7fa13b990ac8, size=1, t='mitogen.Pool.0940.28').get() wake -> Receiver(Router(Broker(04a8)), 110)
[mux  1146622] 12:43:45.601482 D mitogen.io: Receiver(Router(Broker(04a8)), 110).get(timeout=None, block=False)
[mux  1146622] 12:43:45.601613 D mitogen.io: Latch(0x7fa13b990a20, size=1, t='mitogen.Pool.0940.28').get(timeout=None, block=False)
[mux  1146622] 12:43:45.601745 D mitogen.io: Latch(0x7fa13b990a20, size=1, t='mitogen.Pool.0940.28').get() -> Message(0, 1009, 0, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693)
[mux  1146622] 12:43:45.601889 D mitogen.io: Message(0, 1009, 0, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693).unpickle()
[mux  1146622] 12:43:45.602087 D mitogen.io: Message(0, 1009, 0, 110, 1000, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..693).unpickle()
[mux  1146622] 12:43:45.602480 D mitogen.io: Latch(0x7fa118725550, size=0, t='mitogen.Pool.0940.28').put({'context': Context(2, 'ssh.nwra-ap2.nwra.com'), 'via': None, 'init_child_result': {'fork_context': Context(3, 'fork.27764'), 'home_dir': '/root', 'good_temp_dir': '/tmp'}, 'msg': None})
[mux  1146622] 12:43:45.602633 D mitogen.io: Latch(0x7fa118725550, size=1, t='mitogen.Pool.0940.28').get(timeout=None, block=True)
[mux  1146622] 12:43:45.602767 D mitogen.io: Latch(0x7fa118725550, size=1, t='mitogen.Pool.0940.28').get() -> {'context': Context(2, 'ssh.nwra-ap2.nwra.com'), 'via': None, 'init_child_result': {'fork_context': Context(3, 'fork.27764'), 'home_dir': '/root', 'good_temp_dir': '/tmp'}, 'msg': None}
[mux  1146622] 12:43:45.603001 D mitogen.io: Waker(fd=6/8).defer() [fd=8]
[mux  1146622] 12:43:45.603240 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.Pool.0940.28').get(timeout=None, block=True)
[mux  1146622] 12:43:45.603395 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.Pool.0940.28')._get_sleep(timeout=None, block=True, fd=67/68)
[mux  1146622] 12:43:45.603540 D mitogen.io: PollPoller.poll(None)
[mux  1146622] 12:43:45.603693 D mitogen.io: EpollPoller: POLLIN: 6
[mux  1146622] 12:43:45.603835 D mitogen.io: Waker(fd=6/8).on_receive()
[mux  1146622] 12:43:45.603971 D mitogen.io: Router(Broker(04a8))._async_route(Message(1009, 0, 0, 1000, None, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247), None)
[mux  1146622] 12:43:45.604173 D mitogen.io: MitogenProtocol(unix_client.1146768)._send(Message(1009, 0, 0, 1000, None, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247))
[mux  1146622] 12:43:45.604396 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:45.604429 D mitogen.io: Poller: POLLIN for 12
[mux  1146622] 12:43:45.604559 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:45.604610 D mitogen.io: MitogenProtocol(unix_listener.1146622).on_receive()
[task 1146768] 12:43:45.605243 D mitogen.io: Router(Broker(3e48))._async_route(Message(1009, 0, 0, 1000, 0, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247), <Stream unix_listener.1146622 #dd30>)
[task 1146768] 12:43:45.605402 D mitogen.io: Receiver(Router(Broker(3e48)), 1000)._on_receive(Message(1009, 0, 0, 1000, 0, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247))
[task 1146768] 12:43:45.605537 D mitogen.io: Latch(0x7fa13b00c940, size=0, t='mitogen.broker').put(Message(1009, 0, 0, 1000, 0, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247))
[task 1146768] 12:43:45.605673 D mitogen.io: Latch(0x7fa13b00c940, size=1, t='mitogen.broker').put() -> waking wfd=14
[task 1146768] 12:43:45.605829 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[task 1146768] 12:43:45.605958 D mitogen.io: Poller.poll(None)
[task 1146768] 12:43:45.606163 D mitogen.io: PollPoller: POLLIN|POLLHUP for 13
[task 1146768] 12:43:45.606320 D mitogen.io: Latch(0x7fa13b00c940, size=1, t='MainThread').get() wake -> Message(1009, 0, 0, 1000, 0, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247)
[task 1146768] 12:43:45.606462 D mitogen.io: Message(1009, 0, 0, 1000, 0, b'\x80\x02}q\x00(X\x07\x00\x00\x00contextq\x01cmitogen.core\n_unpickle_contex'..247).unpickle()
[task 1146768] 12:43:45.607814 D ansible_mitogen.planner: <class 'ansible_mitogen.planner.BinaryPlanner'> rejected 'uci'
[task 1146768] 12:43:45.607962 D ansible_mitogen.planner: <class 'ansible_mitogen.planner.NewStylePlanner'> rejected 'uci'
[task 1146768] 12:43:45.608099 D ansible_mitogen.planner: <class 'ansible_mitogen.planner.JsonArgsPlanner'> rejected 'uci'
[task 1146768] 12:43:45.608241 D ansible_mitogen.planner: <class 'ansible_mitogen.planner.WantJsonPlanner'> rejected 'uci'
[task 1146768] 12:43:45.608368 D ansible_mitogen.planner: <class 'ansible_mitogen.planner.OldStylePlanner'> accepted 'uci' (filename '/export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py')
[task 1146768] 12:43:45.608622 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method Receiver._on_receive of Receiver(Router(Broker(3e48)), None)>, 1001, False)
[task 1146768] 12:43:45.608770 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:45.608911 D mitogen.io: Receiver(Router(Broker(3e48)), 1001).get(timeout=None, block=True)
[task 1146768] 12:43:45.609040 D mitogen.io: Latch(0x7fa13b079048, size=0, t='MainThread').get(timeout=None, block=True)
[task 1146768] 12:43:45.609203 D mitogen.io: Latch(0x7fa13b079048, size=0, t='MainThread')._get_sleep(timeout=None, block=True, fd=13/14)
[task 1146768] 12:43:45.609335 D mitogen.io: PollPoller.poll(None)
[task 1146768] 12:43:45.609474 D mitogen.io: Poller: POLLIN for 10
[task 1146768] 12:43:45.609633 D mitogen.io: Waker(fd=10/11).on_receive()
[task 1146768] 12:43:45.609802 D mitogen.io: Router(Broker(3e48))._async_route(Message(0, 1009, 1009, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351), None)
[task 1146768] 12:43:45.609947 D mitogen.io: MitogenProtocol(unix_listener.1146622)._send(Message(0, 1009, 1009, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351))
[task 1146768] 12:43:45.610181 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[mux  1146622] 12:43:45.610191 D mitogen.io: EpollPoller: POLLIN: 75
[task 1146768] 12:43:45.610355 D mitogen.io: Poller.poll(None)
[mux  1146622] 12:43:45.610455 D mitogen.io: MitogenProtocol(unix_client.1146768).on_receive()
[mux  1146622] 12:43:45.610702 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 1009, 1009, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351), <Stream unix_client.1146768 #5080>)
[mux  1146622] 12:43:45.610879 D mitogen.io: Receiver(Router(Broker(04a8)), 110)._on_receive(Message(0, 1009, 0, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351))
[mux  1146622] 12:43:45.611132 D mitogen.io: Latch(0x7fa13b990a20, size=0, t='mitogen.broker').put(Message(0, 1009, 0, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351))
[mux  1146622] 12:43:45.611336 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.broker').put(Receiver(Router(Broker(04a8)), 110))
[mux  1146622] 12:43:45.611554 D mitogen.io: Latch(0x7fa13b990ac8, size=1, t='mitogen.broker').put() -> waking wfd=70
[mux  1146622] 12:43:45.611805 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:45.611987 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:45.612155 D mitogen.io: PollPoller: POLLIN|POLLHUP for 69
[mux  1146622] 12:43:45.612363 D mitogen.io: Latch(0x7fa13b990ac8, size=1, t='mitogen.Pool.0940.29').get() wake -> Receiver(Router(Broker(04a8)), 110)
[mux  1146622] 12:43:45.612525 D mitogen.io: Receiver(Router(Broker(04a8)), 110).get(timeout=None, block=False)
[mux  1146622] 12:43:45.612662 D mitogen.io: Latch(0x7fa13b990a20, size=1, t='mitogen.Pool.0940.29').get(timeout=None, block=False)
[mux  1146622] 12:43:45.612790 D mitogen.io: Latch(0x7fa13b990a20, size=1, t='mitogen.Pool.0940.29').get() -> Message(0, 1009, 0, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351)
[mux  1146622] 12:43:45.612930 D mitogen.io: Message(0, 1009, 0, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351).unpickle()
[mux  1146622] 12:43:45.613136 D mitogen.io: Message(0, 1009, 0, 110, 1001, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x1b\x00\x00\x00propa'..351).unpickle()
[mux  1146622] 12:43:45.613304 D mitogen.service: caching small file /export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py
[mux  1146622] 12:43:45.613748 D mitogen.service: requesting Context(2, 'ssh.nwra-ap2.nwra.com') cache and forward small file to Context(2, 'ssh.nwra-ap2.nwra.com'): /export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py
[mux  1146622] 12:43:45.613997 D mitogen.io: Router(Broker(04a8)).add_handler(<bound method Receiver._on_receive of Receiver(Router(Broker(04a8)), None)>, 1004, False)
[mux  1146622] 12:43:45.614168 D mitogen.io: Waker(fd=6/8).defer() [fd=8]
[mux  1146622] 12:43:45.614353 D mitogen.io: Waker(fd=6/8).defer() [fd=8]
[mux  1146622] 12:43:45.614565 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.Pool.0940.29').get(timeout=None, block=True)
[mux  1146622] 12:43:45.614766 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.Pool.0940.29')._get_sleep(timeout=None, block=True, fd=69/70)
[mux  1146622] 12:43:45.614899 D mitogen.io: PollPoller.poll(None)
[mux  1146622] 12:43:45.615169 D mitogen.io: EpollPoller: POLLIN: 6
[mux  1146622] 12:43:45.615376 D mitogen.io: Waker(fd=6/8).on_receive()
[mux  1146622] 12:43:45.615582 D mitogen.io: Router(Broker(04a8))._async_route(Message(2, 0, 0, 110, 1004, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x11\x00\x00\x00store'..5159), None)
[mux  1146622] 12:43:45.615777 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com)._send(Message(2, 0, 0, 110, 1004, b'\x80\x02X\x1f\x00\x00\x00mitogen.service.PushFileServiceq\x00X\x11\x00\x00\x00store'..5159))
[mux  1146622] 12:43:45.616015 D mitogen.io: Router(Broker(04a8))._async_route(Message(1009, 0, 0, 1001, None, b'\x80\x02N.'..4), None)
[mux  1146622] 12:43:45.616178 D mitogen.io: MitogenProtocol(unix_client.1146768)._send(Message(1009, 0, 0, 1001, None, b'\x80\x02N.'..4))
[mux  1146622] 12:43:45.616379 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:45.616399 D mitogen.io: Poller: POLLIN for 12
[mux  1146622] 12:43:45.616558 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:45.616701 D mitogen.io: MitogenProtocol(unix_listener.1146622).on_receive()
[mux  1146622] 12:43:45.616767 D mitogen.io: EpollPoller: POLLIN: 6
[mux  1146622] 12:43:45.616916 D mitogen.io: Waker(fd=6/8).on_receive()
[task 1146768] 12:43:45.616942 D mitogen.io: Router(Broker(3e48))._async_route(Message(1009, 0, 0, 1001, 0, b'\x80\x02N.'..4), <Stream unix_listener.1146622 #dd30>)
[mux  1146622] 12:43:45.617088 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:45.617172 D mitogen.io: Receiver(Router(Broker(3e48)), 1001)._on_receive(Message(1009, 0, 0, 1001, 0, b'\x80\x02N.'..4))
[mux  1146622] 12:43:45.617319 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:45.617376 D mitogen.io: Latch(0x7fa13b079048, size=0, t='mitogen.broker').put(Message(1009, 0, 0, 1001, 0, b'\x80\x02N.'..4))
[task 1146768] 12:43:45.617583 D mitogen.io: Latch(0x7fa13b079048, size=1, t='mitogen.broker').put() -> waking wfd=14
[task 1146768] 12:43:45.617808 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[task 1146768] 12:43:45.618006 D mitogen.io: Poller.poll(None)
[task 1146768] 12:43:45.618232 D mitogen.io: PollPoller: POLLIN|POLLHUP for 13
[task 1146768] 12:43:45.618448 D mitogen.io: Latch(0x7fa13b079048, size=1, t='MainThread').get() wake -> Message(1009, 0, 0, 1001, 0, b'\x80\x02N.'..4)
[task 1146768] 12:43:45.618666 D mitogen.io: Message(1009, 0, 0, 1001, 0, b'\x80\x02N.'..4).unpickle()
[task 1146768] 12:43:45.619123 D mitogen.parent: starting function call to ssh.nwra-ap2.nwra.com: ansible_mitogen.target.run_module(kwargs={'runner_name': 'OldStyleRunner', 'module': 'uci', 'path': '/export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py', 'json_args': '{"command": "set", "key": "system.@system[0]", "value": {"log_ip": "10.0.1.34", "log_port": "514"}, "_ansible_check_mode": false, "_ansible_no_log": false, "_ansible_debug": false, "_ansible_diff": false, "_ansible_verbosity": 4, "_ansible_version": "2.10.16", "_ansible_module_name": "uci", "_ansible_syslog_facility": "LOG_USER", "_ansible_selinux_special_fs": ["fuse", "nfs", "vboxsf", "ramfs", "9p", "vfat"], "_ansible_string_conversion_action": "warn", "_ansible_socket": null, "_ansible_shell_executable": "/bin/sh", "_ansible_keep_remote_files": false, "_ansible_tmpdir": null, "_ansible_remote_tmp": "/tmp"}', 'env': {}, 'interpreter_fragment': '/usr/bin/python3', 'is_python': False, 'good_temp_dir': '/tmp', 'cwd': None, 'extra_env': None, 'emulate_tty': True, 'service_context': Context(0, None)})
[task 1146768] 12:43:45.619474 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method Receiver._on_receive of Receiver(Router(Broker(3e48)), None)>, 1002, False)
[task 1146768] 12:43:45.619634 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:45.619780 D mitogen.io: Receiver(Router(Broker(3e48)), 1002).get(timeout=None, block=True)
[task 1146768] 12:43:45.619909 D mitogen.io: Latch(0x7fa13b079518, size=0, t='MainThread').get(timeout=None, block=True)
[task 1146768] 12:43:45.620059 D mitogen.io: Latch(0x7fa13b079518, size=0, t='MainThread')._get_sleep(timeout=None, block=True, fd=13/14)
[task 1146768] 12:43:45.620203 D mitogen.io: PollPoller.poll(None)
[task 1146768] 12:43:45.620342 D mitogen.io: Poller: POLLIN for 10
[task 1146768] 12:43:45.620480 D mitogen.io: Waker(fd=10/11).on_receive()
[task 1146768] 12:43:45.620787 D mitogen.io: Router(Broker(3e48))._async_route(Message(2, 1009, 1009, 101, 1002, b'\x80\x02(X3\x00\x00\x00barry.cora.nwra.com-1146768-7fa146743b80-2'..1184), None)
[task 1146768] 12:43:45.620994 D mitogen.io: MitogenProtocol(unix_listener.1146622)._send(Message(2, 1009, 1009, 101, 1002, b'\x80\x02(X3\x00\x00\x00barry.cora.nwra.com-1146768-7fa146743b80-2'..1184))
[task 1146768] 12:43:45.621174 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[mux  1146622] 12:43:45.621220 D mitogen.io: EpollPoller: POLLIN: 75
[task 1146768] 12:43:45.621305 D mitogen.io: Poller.poll(None)
[mux  1146622] 12:43:45.621430 D mitogen.io: MitogenProtocol(unix_client.1146768).on_receive()
[mux  1146622] 12:43:45.621593 D mitogen.io: Router(Broker(04a8))._async_route(Message(2, 1009, 1009, 101, 1002, b'\x80\x02(X3\x00\x00\x00barry.cora.nwra.com-1146768-7fa146743b80-2'..1184), <Stream unix_client.1146768 #5080>)
[mux  1146622] 12:43:45.621835 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com)._send(Message(2, 1009, 0, 101, 1002, b'\x80\x02(X3\x00\x00\x00barry.cora.nwra.com-1146768-7fa146743b80-2'..1184))
[mux  1146622] 12:43:45.621995 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:45.622233 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:45.665205 D mitogen.io: EpollPoller: POLLIN: 76
[mux  1146622] 12:43:45.665465 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com).on_receive()
[mux  1146622] 12:43:45.665629 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 2, 2, 102, 0, b'mitogen.service\x0010\x00PushFileService().store_and_for'..216), <Stream ssh.nwra-ap2.nwra.com #0cc0>)
[mux  1146622] 12:43:45.665787 D mitogen.service.[ssh.nwra-ap2.nwra.com]: PushFileService().store_and_forward('/export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py', [blob: 4794 bytes], Context(2, 'ssh.nwra-ap2.nwra.com')) 'mitogen.Pool.c990.0'
[mux  1146622] 12:43:45.665965 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:45.666099 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:45.705533 D mitogen.io: EpollPoller: POLLIN: 76
[mux  1146622] 12:43:45.705799 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com).on_receive()
[mux  1146622] 12:43:45.705965 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 2, 2, 102, 0, b"mitogen\x0010\x00Dispatcher: dispatching ('barry.cora.nw"..1129), <Stream ssh.nwra-ap2.nwra.com #0cc0>)
[mux  1146622] 12:43:45.706193 D mitogen.[ssh.nwra-ap2.nwra.com]: Dispatcher: dispatching ('barry.cora.nwra.com-1146768-7fa146743b80-2dba601396', 'ansible_mitogen.target', None, 'run_module', (), Kwargs({'kwargs': {'runner_name': 'OldStyleRunner', 'module': 'uci', 'path': '/export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py', 'json_args': '{"command": "set", "key": "system.@system[0]", "value": {"log_ip": "10.0.1.34", "log_port": "514"}, "_ansible_check_mode": false, "_ansible_no_log": false, "_ansible_debug": false, "_ansible_diff": false, "_ansible_verbosity": 4, "_ansible_version": "2.10.16", "_ansible_module_name": "uci", "_ansible_syslog_facility": "LOG_USER", "_ansible_selinux_special_fs": ["fuse", "nfs", "vboxsf", "ramfs", "9p", "vfat"], "_ansible_string_conversion_action": "warn", "_ansible_socket": null, "_ansible_shell_executable": "/bin/sh", "_ansible_keep_remote_files": false, "_ansible_tmpdir": null, "_ansible_remote_tmp": "/tmp"}', 'env': {}, 'interpreter_fragment': '/usr/bin/python3', 'is_python': False, 'good_temp_dir': '/tmp', 'cwd': None, 'extra_env': None, 'emulate_tty': True, 'service_context': Context(0, 'master')}}))
[mux  1146622] 12:43:45.706336 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:45.706468 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:45.715377 D mitogen.io: EpollPoller: POLLIN: 76
[mux  1146622] 12:43:45.715575 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com).on_receive()
[mux  1146622] 12:43:45.715733 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 2, 2, 102, 0, b"ansible_mitogen.target\x0010\x00exec_args(['/bin/sh', '-"..201), <Stream ssh.nwra-ap2.nwra.com #0cc0>)
[mux  1146622] 12:43:45.715882 D ansible_mitogen.target.[ssh.nwra-ap2.nwra.com]: exec_args(['/bin/sh', '-c', '/usr/bin/python3 /tmp/ansible_mitogen_runner_7tb6few_/uci.py /tmp/ansible_mitogen_runner_7tb6few_/ansible_mitogennclezlg0-args'], ..., chdir=None)
[mux  1146622] 12:43:45.716079 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:45.716293 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:46.065212 D mitogen.io: EpollPoller: POLLIN: 76
[mux  1146622] 12:43:46.065488 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com).on_receive()
[mux  1146622] 12:43:46.065658 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 2, 2, 102, 0, b'mitogen\x0010\x00Dispatcher: Message(2, 1009, 0, 101, 10'..170), <Stream ssh.nwra-ap2.nwra.com #0cc0>)
[mux  1146622] 12:43:46.065930 D mitogen.[ssh.nwra-ap2.nwra.com]: Dispatcher: Message(2, 1009, 0, 101, 1002, b'\x80\x02(X3\x00\x00\x00barry.cora.nwra.com-1146768-7fa146743b80-2'..1184) -> {'rc': 0, 'stdout': '', 'stderr': ''}
[mux  1146622] 12:43:46.066074 D mitogen.io: Router(Broker(04a8))._async_route(Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54), <Stream ssh.nwra-ap2.nwra.com #0cc0>)
[mux  1146622] 12:43:46.066277 D mitogen.io: MitogenProtocol(unix_client.1146768)._send(Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54))
[mux  1146622] 12:43:46.066464 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:46.066493 D mitogen.io: Poller: POLLIN for 12
[mux  1146622] 12:43:46.066627 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:46.066721 D mitogen.io: MitogenProtocol(unix_listener.1146622).on_receive()
[task 1146768] 12:43:46.066897 D mitogen.io: Router(Broker(3e48))._async_route(Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54), <Stream unix_listener.1146622 #dd30>)
[task 1146768] 12:43:46.067122 D mitogen.io: Receiver(Router(Broker(3e48)), 1002)._on_receive(Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54))
[task 1146768] 12:43:46.067269 D mitogen.io: Latch(0x7fa13b079518, size=0, t='mitogen.broker').put(Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54))
[task 1146768] 12:43:46.067414 D mitogen.io: Latch(0x7fa13b079518, size=1, t='mitogen.broker').put() -> waking wfd=14
[task 1146768] 12:43:46.067571 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[task 1146768] 12:43:46.067706 D mitogen.io: Poller.poll(None)
[task 1146768] 12:43:46.067852 D mitogen.io: PollPoller: POLLIN|POLLHUP for 13
[task 1146768] 12:43:46.068001 D mitogen.io: Latch(0x7fa13b079518, size=1, t='MainThread').get() wake -> Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54)
[task 1146768] 12:43:46.068209 D mitogen.io: Message(1009, 2, 2, 1002, 0, b'\x80\x02}q\x00(X\x02\x00\x00\x00rcq\x01K\x00X\x06\x00\x00\x00stdoutq\x02X\x00\x00\x00\x00q\x03X\x06\x00\x00\x00stderrq\x04'..54).unpickle()
[task 1146768] 12:43:46.068411 D ansible_mitogen.connection: Call took 449 ms: ansible_mitogen.target.run_module(kwargs={'runner_name': 'OldStyleRunner', 'module': 'uci', 'path': '/export/home/orion-admin/ansible-boulder/roles/gekmihesg.openwrt/library/uci.py', 'json_args': '{"command": "set", "key": "system.@system[0]", "value": {"log_ip": "10.0.1.34", "log_port": "514"}, "_ansible_check_mode": false, "_ansible_no_log": false, "_ansible_debug": false, "_ansible_diff": false, "_ansible_verbosity": 4, "_ansible_version": "2.10.16", "_ansible_module_name": "uci", "_ansible_syslog_facility": "LOG_USER", "_ansible_selinux_special_fs": ["fuse", "nfs", "vboxsf", "ramfs", "9p", "vfat"], "_ansible_string_conversion_action": "warn", "_ansible_socket": null, "_ansible_shell_executable": "/bin/sh", "_ansible_keep_remote_files": false, "_ansible_tmpdir": null, "_ansible_remote_tmp": "/tmp"}', 'env': {}, 'interpreter_fragment': '/usr/bin/python3', 'is_python': False, 'good_temp_dir': '/tmp', 'cwd': None, 'extra_env': None, 'emulate_tty': True, 'service_context': Context(0, None)})
[task 1146768] 12:43:46.068763 D ansible_mitogen.mixins: _remove_tmp_path(None)
[task 1146768] 12:43:46.068909 D ansible_mitogen.mixins: _remove_tmp_path(None)
[task 1146768] 12:43:46.069112 D mitogen.parent: starting no-reply function call to 'ssh.nwra-ap2.nwra.com': mitogen.core.Dispatcher.forget_chain('barry.cora.nwra.com-1146768-7fa146743b80-2dba601396')
[task 1146768] 12:43:46.069310 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:46.069556 D mitogen.io: Router(Broker(3e48)).add_handler(<bound method Receiver._on_receive of Receiver(Router(Broker(3e48)), None)>, 1003, False)
[task 1146768] 12:43:46.069705 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:46.069844 D mitogen.io: Receiver(Router(Broker(3e48)), 1003).get(timeout=None, block=True)
[task 1146768] 12:43:46.069974 D mitogen.io: Latch(0x7fa13a74d828, size=0, t='MainThread').get(timeout=None, block=True)
[task 1146768] 12:43:46.070133 D mitogen.io: Latch(0x7fa13a74d828, size=0, t='MainThread')._get_sleep(timeout=None, block=True, fd=13/14)
[task 1146768] 12:43:46.070270 D mitogen.io: PollPoller.poll(None)
[task 1146768] 12:43:46.070409 D mitogen.io: Poller: POLLIN for 10
[task 1146768] 12:43:46.070546 D mitogen.io: Waker(fd=10/11).on_receive()
[task 1146768] 12:43:46.070857 D mitogen.io: Router(Broker(3e48))._async_route(Message(2, 1009, 1009, 101, None, b'\x80\x02(NX\x0c\x00\x00\x00mitogen.coreq\x00X\n\x00\x00\x00Dispatcherq\x01X\x0c\x00\x00\x00forge'..156), None)
[task 1146768] 12:43:46.071035 D mitogen.io: MitogenProtocol(unix_listener.1146622)._send(Message(2, 1009, 1009, 101, None, b'\x80\x02(NX\x0c\x00\x00\x00mitogen.coreq\x00X\n\x00\x00\x00Dispatcherq\x01X\x0c\x00\x00\x00forge'..156))
[task 1146768] 12:43:46.071236 D mitogen.io: Router(Broker(3e48))._async_route(Message(0, 1009, 1009, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179), None)
[mux  1146622] 12:43:46.071281 D mitogen.io: EpollPoller: POLLIN: 75
[task 1146768] 12:43:46.071378 D mitogen.io: MitogenProtocol(unix_listener.1146622)._send(Message(0, 1009, 1009, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179))
[mux  1146622] 12:43:46.071461 D mitogen.io: MitogenProtocol(unix_client.1146768).on_receive()
[task 1146768] 12:43:46.071584 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[mux  1146622] 12:43:46.071627 D mitogen.io: Router(Broker(04a8))._async_route(Message(2, 1009, 1009, 101, 0, b'\x80\x02(NX\x0c\x00\x00\x00mitogen.coreq\x00X\n\x00\x00\x00Dispatcherq\x01X\x0c\x00\x00\x00forge'..156), <Stream unix_client.1146768 #5080>)
[task 1146768] 12:43:46.071727 D mitogen.io: Poller.poll(None)
[mux  1146622] 12:43:46.071775 D mitogen.io: MitogenProtocol(ssh.nwra-ap2.nwra.com)._send(Message(2, 1009, 0, 101, 0, b'\x80\x02(NX\x0c\x00\x00\x00mitogen.coreq\x00X\n\x00\x00\x00Dispatcherq\x01X\x0c\x00\x00\x00forge'..156))
[task 1146768] 12:43:46.071914 D mitogen.io: Poller: POLLIN for 10
[mux  1146622] 12:43:46.071936 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:46.072076 D mitogen.io: Waker(fd=10/11).on_receive()
[mux  1146622] 12:43:46.072095 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:46.072229 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[mux  1146622] 12:43:46.072243 D mitogen.io: EpollPoller: POLLIN: 75
[task 1146768] 12:43:46.072358 D mitogen.io: Poller.poll(None)
[mux  1146622] 12:43:46.072378 D mitogen.io: MitogenProtocol(unix_client.1146768).on_receive()
[mux  1146622] 12:43:46.072525 D mitogen.io: Router(Broker(04a8))._async_route(Message(0, 1009, 1009, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179), <Stream unix_client.1146768 #5080>)
[mux  1146622] 12:43:46.072667 D mitogen.io: Receiver(Router(Broker(04a8)), 110)._on_receive(Message(0, 1009, 0, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179))
[mux  1146622] 12:43:46.072801 D mitogen.io: Latch(0x7fa13b990a20, size=0, t='mitogen.broker').put(Message(0, 1009, 0, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179))
[mux  1146622] 12:43:46.072952 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.broker').put(Receiver(Router(Broker(04a8)), 110))
[mux  1146622] 12:43:46.073088 D mitogen.io: Latch(0x7fa13b990ac8, size=1, t='mitogen.broker').put() -> waking wfd=72
[mux  1146622] 12:43:46.073263 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[mux  1146622] 12:43:46.073391 D mitogen.io: EpollPoller.poll(None)
[mux  1146622] 12:43:46.073580 D mitogen.io: PollPoller: POLLIN|POLLHUP for 71
[mux  1146622] 12:43:46.073767 D mitogen.io: Latch(0x7fa13b990ac8, size=1, t='mitogen.Pool.0940.30').get() wake -> Receiver(Router(Broker(04a8)), 110)
[mux  1146622] 12:43:46.073909 D mitogen.io: Receiver(Router(Broker(04a8)), 110).get(timeout=None, block=False)
[mux  1146622] 12:43:46.074071 D mitogen.io: Latch(0x7fa13b990a20, size=1, t='mitogen.Pool.0940.30').get(timeout=None, block=False)
[mux  1146622] 12:43:46.074316 D mitogen.io: Latch(0x7fa13b990a20, size=1, t='mitogen.Pool.0940.30').get() -> Message(0, 1009, 0, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179)
[mux  1146622] 12:43:46.074457 D mitogen.io: Message(0, 1009, 0, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179).unpickle()
[mux  1146622] 12:43:46.074635 D mitogen.io: Message(0, 1009, 0, 110, 1003, b"\x80\x02X'\x00\x00\x00ansible_mitogen.services.ContextServiceq\x00X\x03"..179).unpickle()
[mux  1146622] 12:43:46.074795 D ansible_mitogen.services: decrementing reference count for Context(2, 'ssh.nwra-ap2.nwra.com')
[mux  1146622] 12:43:46.075042 D mitogen.io: Waker(fd=6/8).defer() [fd=8]
[mux  1146622] 12:43:46.075292 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.Pool.0940.30').get(timeout=None, block=True)
[mux  1146622] 12:43:46.075488 D mitogen.io: Latch(0x7fa13b990ac8, size=0, t='mitogen.Pool.0940.30')._get_sleep(timeout=None, block=True, fd=71/72)
[mux  1146622] 12:43:46.075615 D mitogen.io: PollPoller.poll(None)
[mux  1146622] 12:43:46.075754 D mitogen.io: EpollPoller: POLLIN: 6
[mux  1146622] 12:43:46.075889 D mitogen.io: Waker(fd=6/8).on_receive()
[mux  1146622] 12:43:46.076020 D mitogen.io: Router(Broker(04a8))._async_route(Message(1009, 0, 0, 1003, None, b'\x80\x02N.'..4), None)
[mux  1146622] 12:43:46.076233 D mitogen.io: MitogenProtocol(unix_client.1146768)._send(Message(1009, 0, 0, 1003, None, b'\x80\x02N.'..4))
[mux  1146622] 12:43:46.076389 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:46.076461 D mitogen.io: Poller: POLLIN for 12
[mux  1146622] 12:43:46.076517 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:46.076649 D mitogen.io: MitogenProtocol(unix_listener.1146622).on_receive()
[task 1146768] 12:43:46.076838 D mitogen.io: Router(Broker(3e48))._async_route(Message(1009, 0, 0, 1003, 0, b'\x80\x02N.'..4), <Stream unix_listener.1146622 #dd30>)
[task 1146768] 12:43:46.076988 D mitogen.io: Receiver(Router(Broker(3e48)), 1003)._on_receive(Message(1009, 0, 0, 1003, 0, b'\x80\x02N.'..4))
[task 1146768] 12:43:46.077163 D mitogen.io: Latch(0x7fa13a74d828, size=0, t='mitogen.broker').put(Message(1009, 0, 0, 1003, 0, b'\x80\x02N.'..4))
[task 1146768] 12:43:46.077301 D mitogen.io: Latch(0x7fa13a74d828, size=1, t='mitogen.broker').put() -> waking wfd=14
[task 1146768] 12:43:46.077450 D mitogen.io: Broker(3e48)._loop_once(None, Poller)
[task 1146768] 12:43:46.077579 D mitogen.io: Poller.poll(None)
[task 1146768] 12:43:46.077718 D mitogen.io: PollPoller: POLLIN|POLLHUP for 13
[task 1146768] 12:43:46.077876 D mitogen.io: Latch(0x7fa13a74d828, size=1, t='MainThread').get() wake -> Message(1009, 0, 0, 1003, 0, b'\x80\x02N.'..4)
[task 1146768] 12:43:46.078055 D mitogen.io: Message(1009, 0, 0, 1003, 0, b'\x80\x02N.'..4).unpickle()
[task 1146768] 12:43:46.078252 D mitogen.io: Waker(fd=10/11).defer() [fd=11]
[task 1146768] 12:43:46.078423 D mitogen.io: Poller: POLLIN for 10
[task 1146768] 12:43:46.078560 D mitogen.io: Waker(fd=10/11).on_receive()
[task 1146768] 12:43:46.078707 D mitogen.io: Waker(fd=10/11).defer() [immediate]
[task 1146768] 12:43:46.078863 D mitogen: MitogenProtocol(unix_listener.1146622): disconnecting
[task 1146768] 12:43:46.078995 D mitogen.io: Broker(3e48).stop_receive(<Stream unix_listener.1146622 #dd30>)
[task 1146768] 12:43:46.079177 D mitogen.io: Waker(fd=10/11).defer() [immediate]
[task 1146768] 12:43:46.079329 D mitogen.io: Broker(3e48)._stop_transmit(<Stream unix_listener.1146622 #dd30>)
[task 1146768] 12:43:46.079459 D mitogen.io: <Side of unix_listener.1146622 fd 12>.close()
[task 1146768] 12:43:46.080064 D mitogen.io: <Side of unix_listener.1146622 fd 12>.close()
[mux  1146622] 12:43:46.080162 D mitogen.io: EpollPoller: POLLIN: 75
[task 1146768] 12:43:46.080231 D mitogen: Waker(fd=10/11): disconnecting
[mux  1146622] 12:43:46.080345 D mitogen: <Side of unix_client.1146768 fd 75>: empty read, disconnecting
[task 1146768] 12:43:46.080419 D mitogen.io: Broker(3e48).stop_receive(<Stream default #d8d0>)
[mux  1146622] 12:43:46.080502 D mitogen: MitogenProtocol(unix_client.1146768): disconnecting
[task 1146768] 12:43:46.080552 D mitogen.io: Waker(fd=10/11).defer() [immediate]
[mux  1146622] 12:43:46.080633 D mitogen.io: Broker(04a8).stop_receive(<Stream unix_client.1146768 #5080>)
[task 1146768] 12:43:46.080683 D mitogen.io: Broker(3e48)._stop_transmit(<Stream default #d8d0>)
[mux  1146622] 12:43:46.080761 D mitogen.io: Waker(fd=6/8).defer() [immediate]
[task 1146768] 12:43:46.080811 D mitogen.io: <Side of default fd 10>.close()
[mux  1146622] 12:43:46.080891 D mitogen.io: EpollPoller.stop_receive(75)
[task 1146768] 12:43:46.080963 D mitogen.io: <Side of default fd 11>.close()
[mux  1146622] 12:43:46.081014 D mitogen.io: EpollPoller._control(75)
[mux  1146622] 12:43:46.081155 D mitogen.io: Broker(04a8)._stop_transmit(<Stream unix_client.1146768 #5080>)
[task 1146768] 12:43:46.081241 D mitogen: Router(Broker(3e48)): stats: 0 module requests in 0 ms, 0 sent (0 ms minify time), 0 negative responses. Sent 0.0 kb total, 0.0 kb avg.
[mux  1146622] 12:43:46.081283 D mitogen.io: EpollPoller.stop_transmit(75)
[mux  1146622] 12:43:46.081406 D mitogen.io: EpollPoller._control(75)
[mux  1146622] 12:43:46.081566 D mitogen.io: <Side of unix_client.1146768 fd 75>.close()
[mux  1146622] 12:43:46.081744 D mitogen.io: <Side of unix_client.1146768 fd 75>.close()
[task 1146768] 12:43:46.081741 D mitogen.io: Side._on_fork() closing <Side of unix_listener.1146622 fd 12>
[mux  1146622] 12:43:46.081886 D mitogen.io: Broker(04a8)._loop_once(None, EpollPoller)
[task 1146768] 12:43:46.081885 D mitogen.io: <Side of unix_listener.1146622 fd 12>.close()
[mux  1146622] 12:43:46.082020 D mitogen.io: EpollPoller.poll(None)
[task 1146768] 12:43:46.082031 D mitogen.io: Side._on_fork() closing <Side of unix_listener.1146622 fd 12>
[task 1146768] 12:43:46.082180 D mitogen.io: <Side of unix_listener.1146622 fd 12>.close()
[task 1146768] 12:43:46.082314 D mitogen.io: Side._on_fork() closing <Side of default fd 11>
[task 1146768] 12:43:46.082444 D mitogen.io: <Side of default fd 11>.close()
[task 1146768] 12:43:46.082577 D mitogen.io: Side._on_fork() closing <Side of default fd 10>
[task 1146768] 12:43:46.082726 D mitogen.io: <Side of default fd 10>.close()
fatal: [nwra-ap2.nwra.com]: FAILED! => {
    "changed": false,
    "module_stderr": "",
    "module_stdout": "",
    "msg": "MODULE FAILURE\nSee stdout/stderr for the exact error",
    "rc": 0
}

play:

---
- hosts: openwrt
  remote_user: root
  roles:
    - gekmihesg.openwrt
  tasks:
   - name: Configure logging
     uci:
       command: set
       key: 'system.@system[0]'
       value:
         log_ip: "{{ lookup('dig', logserver) }}"
         log_port: '514'
moreati commented 2 years ago

Correct, Mitogen only supports Python based modules. For roles or tasks that require otherwise you can disable mitogen by overriding the strategy.