@ -155,14 +155,14 @@ class CallbackModule(CallbackBase):
subject = self . itemsubject
subject = self . itemsubject
elif result . _result . get ( ' failed_when_result ' ) is True :
elif result . _result . get ( ' failed_when_result ' ) is True :
subject = " Failed due to ' failed_when ' condition "
subject = " Failed due to ' failed_when ' condition "
elif result . _result . get ( ' exception ' ) :
subject = self . subject_msg ( result . _result [ ' exception ' ] , failtype , - 1 )
elif result . _result . get ( ' msg ' ) :
elif result . _result . get ( ' msg ' ) :
subject = self . subject_msg ( result . _result [ ' msg ' ] , failtype , 0 )
subject = self . subject_msg ( result . _result [ ' msg ' ] , failtype , 0 )
elif result . _result . get ( ' stderr ' ) :
elif result . _result . get ( ' stderr ' ) :
subject = self . subject_msg ( result . _result [ ' stderr ' ] , failtype , - 1 )
subject = self . subject_msg ( result . _result [ ' stderr ' ] , failtype , - 1 )
elif result . _result . get ( ' stdout ' ) :
elif result . _result . get ( ' stdout ' ) :
subject = self . subject_msg ( result . _result [ ' stdout ' ] , failtype , - 1 )
subject = self . subject_msg ( result . _result [ ' stdout ' ] , failtype , - 1 )
elif result . _result . get ( ' exception ' ) : # Unrelated exceptions are added to output :-/
subject = self . subject_msg ( result . _result [ ' exception ' ] , failtype , - 1 )
else :
else :
subject = ' %s : %s ' % ( failtype , result . _task . name or result . _task . action )
subject = ' %s : %s ' % ( failtype , result . _task . name or result . _task . action )
@ -193,12 +193,12 @@ class CallbackModule(CallbackBase):
body + = self . body_blob ( result . _result [ ' msg ' ] , ' message ' )
body + = self . body_blob ( result . _result [ ' msg ' ] , ' message ' )
# Add stdout / stderr / exception / warnings / deprecations
# Add stdout / stderr / exception / warnings / deprecations
if result . _result . get ( ' exception ' ) :
body + = self . body_blob ( result . _result [ ' exception ' ] , ' exception ' )
if result . _result . get ( ' stdout ' ) :
if result . _result . get ( ' stdout ' ) :
body + = self . body_blob ( result . _result [ ' stdout ' ] , ' standard output ' )
body + = self . body_blob ( result . _result [ ' stdout ' ] , ' standard output ' )
if result . _result . get ( ' stderr ' ) :
if result . _result . get ( ' stderr ' ) :
body + = self . body_blob ( result . _result [ ' stderr ' ] , ' error output ' )
body + = self . body_blob ( result . _result [ ' stderr ' ] , ' error output ' )
if result . _result . get ( ' exception ' ) : # Unrelated exceptions are added to output :-/
body + = self . body_blob ( result . _result [ ' exception ' ] , ' exception ' )
if result . _result . get ( ' warnings ' ) :
if result . _result . get ( ' warnings ' ) :
for i in range ( len ( result . _result . get ( ' warnings ' ) ) ) :
for i in range ( len ( result . _result . get ( ' warnings ' ) ) ) :
body + = self . body_blob ( result . _result [ ' warnings ' ] [ i ] , ' exception %d ' % ( i + 1 ) )
body + = self . body_blob ( result . _result [ ' warnings ' ] [ i ] , ' exception %d ' % ( i + 1 ) )
@ -231,4 +231,3 @@ class CallbackModule(CallbackBase):
# Pass item information to task failure
# Pass item information to task failure
self . itemsubject = result . _result [ ' msg ' ]
self . itemsubject = result . _result [ ' msg ' ]
self . itembody + = self . body_blob ( json . dumps ( result . _result , indent = 4 ) , " failed item dump ' %(item)s ' " % result . _result )
self . itembody + = self . body_blob ( json . dumps ( result . _result , indent = 4 ) , " failed item dump ' %(item)s ' " % result . _result )
# self.itembody += self.body_blob(json.dumps(dir(result), indent=4), "failed full dump '%(item)s'" % result._result)