@@ -627,7 +627,7 @@ def run(
627
627
return migration_run_data ["migrate_return_value" ], pr_lazy_json
628
628
629
629
630
- def _compute_time_per_migrator (mctx , migrators ):
630
+ def _compute_time_per_migrator (migrators ):
631
631
# we weight each migrator by the number of available nodes to migrate
632
632
num_nodes = []
633
633
for migrator in tqdm .tqdm (migrators , ncols = 80 , desc = "computing time per migrator" ):
@@ -885,9 +885,7 @@ def _is_migrator_done(_mg_start, good_prs, time_per, pr_limit):
885
885
return False
886
886
887
887
888
- def _run_migrator (
889
- migrator , mctx , temp , time_per , dry_run , git_backend : GitPlatformBackend
890
- ):
888
+ def _run_migrator (migrator , mctx , temp , time_per , git_backend : GitPlatformBackend ):
891
889
_mg_start = time .time ()
892
890
893
891
migrator_name = get_migrator_name (migrator )
@@ -1028,8 +1026,7 @@ def _run_migrator(
1028
1026
os .chdir (BOT_HOME_DIR )
1029
1027
1030
1028
# Write graph partially through
1031
- if not dry_run :
1032
- dump_graph (mctx .graph )
1029
+ dump_graph (mctx .graph )
1033
1030
1034
1031
with filter_reprinted_lines ("rm-tmp" ):
1035
1032
for f in glob .glob ("/tmp/*" ):
@@ -1241,7 +1238,6 @@ def main(ctx: CliContext) -> None:
1241
1238
time_per_migrator ,
1242
1239
tot_time_per_migrator ,
1243
1240
) = _compute_time_per_migrator (
1244
- mctx ,
1245
1241
migrators ,
1246
1242
)
1247
1243
for i , migrator in enumerate (migrators ):
@@ -1265,7 +1261,7 @@ def main(ctx: CliContext) -> None:
1265
1261
1266
1262
for mg_ind , migrator in enumerate (migrators ):
1267
1263
good_prs = _run_migrator (
1268
- migrator , mctx , temp , time_per_migrator [mg_ind ], ctx . dry_run , git_backend
1264
+ migrator , mctx , temp , time_per_migrator [mg_ind ], git_backend
1269
1265
)
1270
1266
if good_prs > 0 :
1271
1267
pass
0 commit comments