File tree 1 file changed +8
-1
lines changed
1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -41,6 +41,8 @@ def main():
41
41
res = line .strip ().split (' ' )
42
42
ip = res [0 ]
43
43
hosts .append (ip )
44
+
45
+ f .close ()
44
46
45
47
# We need to update the partition config file so that the paths are relative to
46
48
# the workspace in the remote machines.
@@ -67,10 +69,15 @@ def main():
67
69
part_files ['edge_feats' ] = '{}/part{}/edge_feat.dgl' .format (args .rel_data_path , part_id )
68
70
part_files ['node_feats' ] = '{}/part{}/node_feat.dgl' .format (args .rel_data_path , part_id )
69
71
part_files ['part_graph' ] = '{}/part{}/graph.dgl' .format (args .rel_data_path , part_id )
72
+
73
+ conf_f .close ()
74
+
70
75
tmp_part_config = '/tmp/{}.json' .format (graph_name )
71
76
with open (tmp_part_config , 'w' ) as outfile :
72
77
json .dump (tmp_part_metadata , outfile , sort_keys = True , indent = 4 )
73
-
78
+
79
+ outfile .close ()
80
+
74
81
# Copy ip config.
75
82
for part_id , ip in enumerate (hosts ):
76
83
remote_path = '{}/{}' .format (args .workspace , args .rel_data_path )
You can’t perform that action at this time.
0 commit comments