Add force for async

C2SM · Dec 19, 2023 · ae5627f · ae5627f
1 parent d6f9b6c
commit ae5627f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/run_chain.py b/run_chain.py
@@ -201,7 +201,7 @@ def run_chain(cfg, force, resume):
     if cfg.is_async:
         # Submit current chunk
         for job in cfg.jobs:
-            if (log_finished_dir / job).exists():
+            if (log_finished_dir / job).exists() and not force:
                 # Skip job if already finished
                 print(f'    └── Skip "{job}" for chunk "{cfg.job_id}"')
                 skip = True