minor fix for conditional in handle func
This commit is contained in:
parent
ddc45ce2eb
commit
115a901773
@ -201,6 +201,10 @@ class ExternalMessageConsumer:
|
|||||||
message_type = message.get('type', RPCMessageType.STATUS)
|
message_type = message.get('type', RPCMessageType.STATUS)
|
||||||
message_data = message.get('data')
|
message_data = message.get('data')
|
||||||
|
|
||||||
|
# We shouldn't get empty messages
|
||||||
|
if message_data is None:
|
||||||
|
return
|
||||||
|
|
||||||
logger.debug(f"Received message of type {message_type}")
|
logger.debug(f"Received message of type {message_type}")
|
||||||
|
|
||||||
# Handle Whitelists
|
# Handle Whitelists
|
||||||
@ -213,10 +217,6 @@ class ExternalMessageConsumer:
|
|||||||
|
|
||||||
# Handle analyzed dataframes
|
# Handle analyzed dataframes
|
||||||
elif message_type == RPCMessageType.ANALYZED_DF:
|
elif message_type == RPCMessageType.ANALYZED_DF:
|
||||||
# This shouldn't happen
|
|
||||||
if message_data is None:
|
|
||||||
return
|
|
||||||
|
|
||||||
key, value = message_data.get('key'), message_data.get('value')
|
key, value = message_data.get('key'), message_data.get('value')
|
||||||
|
|
||||||
if key and value:
|
if key and value:
|
||||||
|
Loading…
Reference in New Issue
Block a user