Fix exception by passing timeout as None
The call method takes a new timeout argument, but not all uses of it were updated to pass the new argument. Change-Id: Ie4377419aafa5606ade803f8e4cd715cb53b1547
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