Skip to content
Snippets Groups Projects
Commit 13ee1826 authored by Masood Malekghassemi's avatar Masood Malekghassemi
Browse files

Use value equality for status codes

parent 7a6b0a42
No related branches found
No related tags found
No related merge requests found
...@@ -182,15 +182,15 @@ class _Kernel(object): ...@@ -182,15 +182,15 @@ class _Kernel(object):
def _on_finish_event(self, operation_id, event, rpc_state): def _on_finish_event(self, operation_id, event, rpc_state):
_no_longer_due(_FINISH, rpc_state, operation_id, self._rpc_states) _no_longer_due(_FINISH, rpc_state, operation_id, self._rpc_states)
if event.status.code is _intermediary_low.Code.OK: if event.status.code == _intermediary_low.Code.OK:
termination = links.Ticket.Termination.COMPLETION termination = links.Ticket.Termination.COMPLETION
elif event.status.code is _intermediary_low.Code.CANCELLED: elif event.status.code == _intermediary_low.Code.CANCELLED:
termination = links.Ticket.Termination.CANCELLATION termination = links.Ticket.Termination.CANCELLATION
elif event.status.code is _intermediary_low.Code.DEADLINE_EXCEEDED: elif event.status.code == _intermediary_low.Code.DEADLINE_EXCEEDED:
termination = links.Ticket.Termination.EXPIRATION termination = links.Ticket.Termination.EXPIRATION
elif event.status.code is _intermediary_low.Code.UNIMPLEMENTED: elif event.status.code == _intermediary_low.Code.UNIMPLEMENTED:
termination = links.Ticket.Termination.REMOTE_FAILURE termination = links.Ticket.Termination.REMOTE_FAILURE
elif event.status.code is _intermediary_low.Code.UNKNOWN: elif event.status.code == _intermediary_low.Code.UNKNOWN:
termination = links.Ticket.Termination.LOCAL_FAILURE termination = links.Ticket.Termination.LOCAL_FAILURE
else: else:
termination = links.Ticket.Termination.TRANSMISSION_FAILURE termination = links.Ticket.Termination.TRANSMISSION_FAILURE
......
...@@ -254,12 +254,12 @@ class _Kernel(object): ...@@ -254,12 +254,12 @@ class _Kernel(object):
rpc_state = self._rpc_states[call] rpc_state = self._rpc_states[call]
_no_longer_due(_FINISH, rpc_state, call, self._rpc_states) _no_longer_due(_FINISH, rpc_state, call, self._rpc_states)
code = event.status.code code = event.status.code
if code is _intermediary_low.Code.OK: if code == _intermediary_low.Code.OK:
return return
if code is _intermediary_low.Code.CANCELLED: if code == _intermediary_low.Code.CANCELLED:
termination = links.Ticket.Termination.CANCELLATION termination = links.Ticket.Termination.CANCELLATION
elif code is _intermediary_low.Code.DEADLINE_EXCEEDED: elif code == _intermediary_low.Code.DEADLINE_EXCEEDED:
termination = links.Ticket.Termination.EXPIRATION termination = links.Ticket.Termination.EXPIRATION
else: else:
termination = links.Ticket.Termination.TRANSMISSION_FAILURE termination = links.Ticket.Termination.TRANSMISSION_FAILURE
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment