breaking: remove old dispatcher (#1097)

Remove the old dispatcher and all related tests and examples.
Fix #1002. Close #522.

Signed-off-by: Jinzhe Zeng <jinzhe.zeng@rutgers.edu>

Author: njzjz

dpgen/arginfo.py

@@ -24,7 +24,7 @@ def general_mdata_arginfo(name: str, tasks: Tuple[str]) -> Argument:
     doc_api_version = "Please set to 1.0"
     doc_deepmd_version = "DeePMD-kit version, e.g. 2.1.3"
     doc_run_mdata = "machine.json file"
-    arg_api_version = Argument("api_version", str, optional=False, doc=doc_api_version)
+    arg_api_version = Argument("api_version", str, default="1.0", optional=True, doc=doc_api_version)
     arg_deepmd_version = Argument(
         "deepmd_version", str, optional=True, default="2", doc=doc_deepmd_version)
 

dpgen/auto_test/common_equi.py

@@ -11,7 +11,6 @@
 from dpgen import dlog
 from dpgen.auto_test.calculator import make_calculator
 from dpgen.auto_test.mpdb import get_structure
-from dpgen.dispatcher.Dispatcher import make_dispatcher
 from packaging.version import Version
 from dpgen.dispatcher.Dispatcher import make_submission
 from dpgen.remote.decide_machine import convert_mdata
@@ -176,21 +175,9 @@ def run_equi(confs,
     work_path = os.getcwd()
     print("%s --> Runing... " % (work_path))
 
-    api_version = mdata.get('api_version', '0.9')
+    api_version = mdata.get('api_version', '1.0')
     if Version(api_version) < Version('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 = make_dispatcher(machine, resources, work_path, run_tasks, group_size)
-        disp.run_jobs(resources,
-                      command,
-                      work_path,
-                      run_tasks,
-                      group_size,
-                      forward_common_files,
-                      forward_files,
-                      backward_files,
-                      outlog='outlog',
-                      errlog='errlog')
+        raise RuntimeError("API version %s has been removed. Please upgrade to 1.0." % api_version)
     elif Version(api_version) >= Version('1.0'):
 
         submission = make_submission(

dpgen/auto_test/common_prop.py

@@ -13,7 +13,6 @@
 from dpgen.auto_test.Vacancy import Vacancy
 from dpgen.auto_test.Gamma import Gamma
 from dpgen.auto_test.calculator import make_calculator
-from dpgen.dispatcher.Dispatcher import make_dispatcher
 from dpgen.dispatcher.Dispatcher import make_submission
 from dpgen.remote.decide_machine import convert_mdata
 from dpgen.auto_test.lib.utils import create_path
@@ -190,21 +189,9 @@ def worker(work_path,
            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', '0.9')
+    api_version = mdata.get('api_version', '1.0')
     if Version(api_version) < Version('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 = make_dispatcher(machine, resources, work_path, run_tasks, group_size)
-        disp.run_jobs(resources,
-                  command,
-                  work_path,
-                  run_tasks,
-                  group_size,
-                  forward_common_files,
-                  forward_files,
-                  backward_files,
-                  outlog='outlog',
-                  errlog='errlog')
+        raise RuntimeError("API version %s has been removed. Please upgrade to 1.0." % api_version)
     elif Version(api_version) >= Version('1.0'):
         submission = make_submission(
                 mdata_machine=machine,