in kernels-mixer/kernels_mixer/websockets.py [0:0]
def is_starting_message(self, incoming_msg):
try:
msg = json_decode(utf8(incoming_msg))
if msg.get("content", {}).get("execution_state", "") == "starting":
return True
except Exception as ex:
pass
return False