cmueller/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Revert "Fix missing persistent connection messages (#68496)" (#69147)

Browse source 
This reverts commit 5f6427b1fc.
as it breaks netconf connection. This will be a temporary measure
for unlocking CI until a proper fix is shipped.
This commit is contained in:
Daniel Mellado 2020-04-27 11:58:57 +02:00 committed by GitHub
parent 91d02e1c1f
commit 9217aeeac1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lib/ansible/cli/scripts/ansible_connection_cli_stub.py
View file

@ -148,8 +148,6 @@ class ConnectionProcess(object):
resp = self.srv.handle_request(data)
signal.alarm(0)
display_messages(self.connection)
if log_messages:
display.display("jsonrpc response: %s" % resp, log_only=True)
@ -199,7 +197,9 @@ class ConnectionProcess(object):
self.sock.close()
if self.connection:
self.connection.close()
display_messages(self.connection)
if self.connection.get_option("persistent_log_messages"):
for _level, message in self.connection.pop_messages():
display.display(message, log_only=True)
except Exception:
pass
finally:
@ -337,24 +337,6 @@ def main():
sys.exit(rc)
def display_messages(connection):
# This should be handled elsewhere, but if this is the last task, nothing will
# come back to collect the messages. So now each task will dump its own messages
# to stdout before logging the response message. This may make some other
# pop_messages calls redundant.
for level, message in connection.pop_messages():
if connection.get_option('persistent_log_messages') and level == "log":
display.display(message, log_only=True)
else:
# These should be keyed by valid method names, but
# fail gracefully just in case.
display_method = getattr(display, level, None)
if display_method:
display_method(message)
else:
display.display((level, message))
if __name__ == '__main__':
display = Display()
main()