fix dispatcher bugs in autotest run

Change-Id: I0e48ec74d0a0d0d6c26988c6e8c28428a362b5d9
deepmodeling · Oct 11, 2021 · a8b940f · a8b940f
1 parent 02037ad
commit a8b940f
Showing 1 changed file with 29 additions and 29 deletions.
diff --git a/dpgen/auto_test/common_equi.py b/dpgen/auto_test/common_equi.py
@@ -159,35 +159,35 @@ def run_equi(confs,
             disp = make_dispatcher(machine, resources, work_path, [run_tasks[ii]], group_size)
             print("%s --> Runing... "%(work_path))
 
-        api_version = mdata.get('api_version', '0.9')
-        if LooseVersion(api_version) < LooseVersion('1.0'):
-            warnings.warn(f"the dpdispatcher will be updated to new version."
-                f"And the interface may be changed. Please check the documents for more details")
-            disp.run_jobs(resources,
-                            command,
-                            work_path,
-                            [run_tasks[ii]],
-                            group_size,
-                            forward_common_files,
-                            forward_files,
-                            backward_files,
-                            outlog='outlog',
-                            errlog='errlog')
-        elif LooseVersion(api_version) >= LooseVersion('1.0'):
-            submission = make_submission(
-                mdata_machine=machine,
-                mdata_resource=resources,
-                commands=[command],
-                work_path=work_path,
-                run_tasks=run_tasks,
-                group_size=group_size,
-                forward_common_files=forward_common_files,
-                forward_files=forward_files,
-                backward_files=backward_files,
-                outlog = 'outlog',
-                errlog = 'errlog'
-            )
-            submission.run_submission()
+            api_version = mdata.get('api_version', '0.9')
+            if LooseVersion(api_version) < LooseVersion('1.0'):
+                warnings.warn(f"the dpdispatcher will be updated to new version."
+                    f"And the interface may be changed. Please check the documents for more details")
+                disp.run_jobs(resources,
+                                command,
+                                work_path,
+                                [run_tasks[ii]],
+                                group_size,
+                                forward_common_files,
+                                forward_files,
+                                backward_files,
+                                outlog='outlog',
+                                errlog='errlog')
+            elif LooseVersion(api_version) >= LooseVersion('1.0'):
+                submission = make_submission(
+                    mdata_machine=machine,
+                    mdata_resource=resources,
+                    commands=[command],
+                    work_path=work_path,
+                    run_tasks=run_tasks,
+                    group_size=group_size,
+                    forward_common_files=forward_common_files,
+                    forward_files=forward_files,
+                    backward_files=backward_files,
+                    outlog = 'outlog',
+                    errlog = 'errlog'
+                )
+                submission.run_submission()
 
 
 def post_equi(confs, inter_param):