Merge "Fix exception by passing timeout as None"
This commit is contained in:
@@ -174,6 +174,6 @@ def fanout_cast(context, topic, msg):
|
||||
|
||||
for consumer in CONSUMERS.get(topic, []):
|
||||
try:
|
||||
consumer.call(context, method, args)
|
||||
consumer.call(context, method, args, None)
|
||||
except rpc_common.RemoteError:
|
||||
pass
|
||||
|
||||
Reference in New Issue
Block a user