fix: preserve property rerun filtering

Fixes #1898

Coding-Agent: Codex

Codex-Version: codex-cli 0.149.0

Model: gpt-5.6-sol

Reasoning-Effort: xhigh

Author: njzjz-bot

dpgen/auto_test/common_prop.py

@@ -167,7 +167,7 @@ def run_property(confs, inter_param, property_list, mdata):
                     worker,
                     (
                         work_path,
-                        all_task,
+                        run_tasks,
                         forward_common_files,
                         forward_files,
                         backward_files,
@@ -187,14 +187,13 @@ def run_property(confs, inter_param, property_list, mdata):
 
 def worker(
     work_path,
-    all_task,
+    run_tasks,
     forward_common_files,
     forward_files,
     backward_files,
     mdata,
     inter_type,
 ):
-    run_tasks = [os.path.basename(ii) for ii in all_task]
     machine, resources, command, group_size = util.get_machine_info(mdata, inter_type)
     api_version = mdata.get("api_version", "1.0")
     if Version(api_version) < Version("1.0"):

tests/auto_test/test_common_prop.py

@@ -0,0 +1,48 @@
+import unittest
+from unittest.mock import MagicMock, patch
+
+from dpgen.auto_test.common_prop import run_property
+
+
+class TestRunProperty(unittest.TestCase):
+    @patch(
+        "dpgen.auto_test.common_prop.convert_mdata", side_effect=lambda data, _: data
+    )
+    @patch("dpgen.auto_test.common_prop.make_calculator")
+    @patch("dpgen.auto_test.common_prop.util.collect_task")
+    @patch("dpgen.auto_test.common_prop.glob.glob")
+    @patch("dpgen.auto_test.common_prop.Pool")
+    def test_only_unfinished_tasks_are_sent_to_worker(
+        self, pool_class, glob_files, collect_task, make_calculator, _convert_mdata
+    ):
+        task_paths = ["/work/task.000000", "/work/task.000001"]
+        glob_files.side_effect = lambda pattern: (
+            task_paths if "task.[0-9]*[0-9]" in pattern else ["conf"]
+        )
+        collect_task.return_value = ["task.000001"]
+
+        calculator = MagicMock()
+        calculator.forward_files.return_value = []
+        calculator.forward_common_files.return_value = []
+        calculator.backward_files.return_value = []
+        make_calculator.return_value = calculator
+
+        pool = MagicMock()
+        result = MagicMock()
+        result.successful.return_value = True
+        pool.apply_async.return_value = result
+        pool_class.return_value = pool
+
+        run_property(
+            ["conf"],
+            {"type": "vasp"},
+            [{"type": "eos"}],
+            {},
+        )
+
+        worker_args = pool.apply_async.call_args.args[1]
+        self.assertEqual(worker_args[1], ["task.000001"])
+
+
+if __name__ == "__main__":
+    unittest.main()