|
18 | 18 | from je_auto_control.utils.logging.loggin_instance import autocontrol_logger
|
19 | 19 | from je_auto_control.utils.package_manager.package_manager_class import package_manager
|
20 | 20 | from je_auto_control.utils.project.create_project_structure import create_project_dir
|
21 |
| -from je_auto_control.utils.scheduler.extend_apscheduler import scheduler_manager |
22 | 21 | from je_auto_control.utils.shell_process.shell_exec import ShellManager
|
23 | 22 | from je_auto_control.utils.start_exe.start_another_process import start_exe
|
24 | 23 | from je_auto_control.utils.test_record.record_test_class import record_action_to_list, test_record_instance
|
@@ -90,15 +89,6 @@ def __init__(self):
|
90 | 89 | "AC_shell_command": ShellManager().exec_shell,
|
91 | 90 | # Another process
|
92 | 91 | "AC_execute_process": start_exe,
|
93 |
| - # Scheduler |
94 |
| - "AC_scheduler_event_trigger": self.scheduler_event_trigger, |
95 |
| - "AC_remove_blocking_scheduler_job": scheduler_manager.remove_blocking_job, |
96 |
| - "AC_remove_nonblocking_scheduler_job": scheduler_manager.remove_nonblocking_job, |
97 |
| - "AC_start_blocking_scheduler": scheduler_manager.start_block_scheduler, |
98 |
| - "AC_start_nonblocking_scheduler": scheduler_manager.start_nonblocking_scheduler, |
99 |
| - "AC_start_all_scheduler": scheduler_manager.start_all_scheduler, |
100 |
| - "AC_shutdown_blocking_scheduler": scheduler_manager.shutdown_blocking_scheduler, |
101 |
| - "AC_shutdown_nonblocking_scheduler": scheduler_manager.shutdown_nonblocking_scheduler, |
102 | 92 | }
|
103 | 93 | # get all builtin function and add to event dict
|
104 | 94 | for function in getmembers(builtins, isbuiltin):
|
@@ -164,15 +154,6 @@ def execute_files(self, execute_files_list: list) -> List[Dict[str, str]]:
|
164 | 154 | execute_detail_list.append(self.execute_action(read_action_json(file)))
|
165 | 155 | return execute_detail_list
|
166 | 156 |
|
167 |
| - def scheduler_event_trigger( |
168 |
| - self, function: str, scheduler_id: str = None, args: Union[list, tuple] = None, |
169 |
| - kwargs: dict = None, scheduler_type: str = "nonblocking", wait_type: str = "secondly", |
170 |
| - wait_value: int = 1, **trigger_args: Any) -> None: |
171 |
| - if scheduler_type == "nonblocking": |
172 |
| - scheduler_event = scheduler_manager.nonblocking_scheduler_event_dict.get(wait_type) |
173 |
| - else: |
174 |
| - scheduler_event = scheduler_manager.blocking_scheduler_event_dict.get(wait_type) |
175 |
| - scheduler_event(self.event_dict.get(function), scheduler_id, args, kwargs, wait_value, **trigger_args) |
176 | 157 |
|
177 | 158 |
|
178 | 159 | executor = Executor()
|
|
0 commit comments