(job_id : str, step_index : int, step_args : Args)
| 301 | |
| 302 | |
| 303 | def process_step(job_id : str, step_index : int, step_args : Args) -> bool: |
| 304 | step_total = job_manager.count_step_total(job_id) |
| 305 | step_args.update(collect_job_args()) |
| 306 | apply_args(step_args, state_manager.set_item) |
| 307 | |
| 308 | logger.info(translator.get('processing_step').format(step_current = step_index + 1, step_total = step_total), __name__) |
| 309 | if common_pre_check() and processors_pre_check(): |
| 310 | error_code = conditional_process() |
| 311 | return error_code == 0 |
| 312 | return False |
| 313 | |
| 314 | |
| 315 | def conditional_process() -> ErrorCode: |
no test coverage detected