@@ -453,8 +453,7 @@ def __append_optimize_op__(op, block):
453
453
if self .has_distributed_lookup_table :
454
454
pserver_index = self .pserver_endpoints .index (endpoint )
455
455
table_opt_block = self ._create_table_optimize_block (
456
- pserver_index , pserver_program , opt_state_block or
457
- pserver_program .global_block ())
456
+ pserver_index , pserver_program , pre_block_idx )
458
457
prefetch_block = self ._create_prefetch_block (
459
458
pserver_index , pserver_program , table_opt_block )
460
459
@@ -665,7 +664,7 @@ def _create_prefetch_block(self, pserver_index, pserver_program,
665
664
return prefetch_block
666
665
667
666
def _create_table_optimize_block (self , pserver_index , pserver_program ,
668
- append_block ):
667
+ pre_block_idx ):
669
668
def _clone_var (block , var , persistable = True ):
670
669
assert isinstance (var , Variable )
671
670
return block .create_var (
@@ -702,7 +701,7 @@ def _clone_var(block, var, persistable=True):
702
701
op for op in self .optimize_ops
703
702
if op .input ("Param" )[0 ] == self .table_name
704
703
][0 ]
705
- table_opt_block = pserver_program .create_block (append_block . idx )
704
+ table_opt_block = pserver_program .create_block (pre_block_idx )
706
705
# only support sgd now
707
706
assert table_opt_op .type == "sgd"
708
707
0 commit comments