提交 eb57fb1d authored 作者: Reyhane Askari's avatar Reyhane Askari

handling several cases of uncompatibale replacement

上级 70129ffb
...@@ -860,11 +860,36 @@ class MergeOptimizer(Optimizer): ...@@ -860,11 +860,36 @@ class MergeOptimizer(Optimizer):
try: try:
fgraph.replace_all_validate(pairs, 'MergeOptimizer') fgraph.replace_all_validate(pairs, 'MergeOptimizer')
except InconsistencyError: except Exception as ex:
success = False if type(ex) is InconsistencyError:
nb_fail += 1 success = False
fgraph.merge_feature.blacklist.append( nb_fail += 1
(pairs[0][0].owner, pairs[0][1].owner)) fgraph.merge_feature.blacklist.append(
(pairs[0][0].owner, pairs[0][1].owner))
elif type(ex) is TypeError:
if (not isinstance(pairs[0][1], pairs[0][0].__class__) or
pairs[0][0].dtype != pairs[0][1].dtype or
pairs[0][0].ndim != pairs[0][1].ndim or
pairs[0][0].broadcastable == pairs[0][1].broadcastable or len(pairs) != 1):
raise
else:
num_broadcastable_dims_0 = sum(pairs[0][0].broadcastable)
num_broadcastable_dims_1 = sum(pairs[0][1].broadcastable)
# select the variable to be removed from the fgraph
if num_broadcastable_dims_0 <= num_broadcastable_dims_1:
selected_var_ind = 1
else:
selected_var_ind = 0
for i, j in zip(pairs[0][selected_var_ind].broadcastable,
pairs[0][1 - selected_var_ind].broadcastable):
if not i and j:
raise
new_broadcast_pattern = theano.tensor.patternbroadcast(
pairs[0][selected_var_ind],
pairs[0][1 - selected_var_ind].broadcastable)
new_pairs = [(new_broadcast_pattern, pairs[0][1 - selected_var_ind])]
fgraph.replace_all_validate(new_pairs, 'MergeOptimizer')
if success: if success:
nb_merged += len(pairs) nb_merged += len(pairs)
if isinstance(pairs[0][0], graph.Constant): if isinstance(pairs[0][0], graph.Constant):
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论