Module coordinator

Structs§

build_import_tasks 🔒
chunk_has_schema_files 🔒
import_tasks_concurrent 🔒: Imports up to task_parallelism data tasks concurrently on the client.
import_tasks_serial 🔒: Imports data tasks one at a time, preserving the original serial behavior.
import_with_resume_session_with_progress 🔒
next_pending_task 🔒: Returns the index of the next task eligible for import, scanning forward from next_idx and skipping tasks already marked Completed (counting each skipped task once toward progress). Advances next_idx past the returned task so each task is scheduled at most once.
persist_failed_best_effort 🔒
prepare_import_resume 🔒
state_mismatch 🔒
task_set_from_config 🔒
task_set_from_state 🔒
update_status_and_save 🔒
validate_config_tasks 🔒
validate_state_matches 🔒