|
9 | 9 |
|
10 | 10 | # -- io.py: pure utilities, atomic I/O, paths, config ----------------------- |
11 | 11 | from .io import ( |
| 12 | + append_framed_json_records, |
| 13 | + append_framed_json_transaction, |
12 | 14 | artifact_path, |
| 15 | + atomic_write_bytes, |
13 | 16 | atomic_write_json, |
14 | 17 | atomic_write_text, |
15 | 18 | batch_artifact_path, |
| 19 | + canonical_megaplan_root, |
| 20 | + commit_journal_transaction, |
| 21 | + committed_framed_json_transactions, |
16 | 22 | collect_git_diff_patch, |
17 | 23 | collect_git_diff_summary, |
18 | 24 | compute_global_batches, |
19 | 25 | compute_task_batches, |
20 | 26 | config_dir, |
21 | 27 | current_iteration_artifact, |
22 | 28 | current_iteration_raw_artifact, |
| 29 | + discard_uncommitted_journal_transaction, |
23 | 30 | detect_available_agents, |
24 | 31 | ensure_runtime_layout, |
| 32 | + find_plan_dir, |
25 | 33 | find_command, |
| 34 | + framed_json_record_bytes, |
| 35 | + fsync_dir, |
| 36 | + fsync_file, |
26 | 37 | get_effective, |
| 38 | + has_any_plan_root, |
| 39 | + journal_blob_promotion, |
| 40 | + journal_bytes_write, |
| 41 | + journal_commit_path, |
| 42 | + journal_event_log, |
| 43 | + journal_prepare_path, |
| 44 | + journal_root, |
| 45 | + journal_text_write, |
27 | 46 | json_dump, |
28 | 47 | list_batch_artifacts, |
29 | 48 | load_config, |
30 | 49 | load_finalize_snapshot, |
31 | 50 | megaplan_root, |
32 | 51 | normalize_text, |
33 | 52 | now_utc, |
| 53 | + orphan_plans_root, |
| 54 | + plan_search_roots, |
34 | 55 | plans_root, |
| 56 | + prepare_journal_transaction, |
35 | 57 | read_json, |
| 58 | + read_committed_framed_json_records, |
| 59 | + recover_journal, |
| 60 | + repo_storage_id, |
36 | 61 | render_final_md, |
37 | 62 | save_config, |
38 | 63 | schemas_root, |
| 64 | + scrub_stale_staging_files, |
39 | 65 | sha256_file, |
40 | 66 | sha256_text, |
41 | 67 | slugify, |
| 68 | + write_journal_commit_marker, |
42 | 69 | ) |
43 | 70 |
|
44 | 71 | # -- phase_runtime.py: centralized runtime policy ---------------------------- |
|
125 | 152 |
|
126 | 153 | __all__ = [ |
127 | 154 | # io |
| 155 | + "append_framed_json_records", |
| 156 | + "append_framed_json_transaction", |
128 | 157 | "artifact_path", |
| 158 | + "atomic_write_bytes", |
129 | 159 | "atomic_write_json", |
130 | 160 | "atomic_write_text", |
131 | 161 | "batch_artifact_path", |
| 162 | + "canonical_megaplan_root", |
| 163 | + "commit_journal_transaction", |
| 164 | + "committed_framed_json_transactions", |
132 | 165 | "collect_git_diff_patch", |
133 | 166 | "collect_git_diff_summary", |
134 | 167 | "compute_global_batches", |
135 | 168 | "compute_task_batches", |
136 | 169 | "config_dir", |
137 | 170 | "current_iteration_artifact", |
138 | 171 | "current_iteration_raw_artifact", |
| 172 | + "discard_uncommitted_journal_transaction", |
139 | 173 | "detect_available_agents", |
140 | 174 | "ensure_runtime_layout", |
| 175 | + "find_plan_dir", |
141 | 176 | "find_command", |
| 177 | + "framed_json_record_bytes", |
| 178 | + "fsync_dir", |
| 179 | + "fsync_file", |
142 | 180 | "get_effective", |
| 181 | + "has_any_plan_root", |
| 182 | + "journal_blob_promotion", |
| 183 | + "journal_bytes_write", |
| 184 | + "journal_commit_path", |
| 185 | + "journal_event_log", |
| 186 | + "journal_prepare_path", |
| 187 | + "journal_root", |
| 188 | + "journal_text_write", |
143 | 189 | "json_dump", |
144 | 190 | "list_batch_artifacts", |
145 | 191 | "load_config", |
146 | 192 | "load_finalize_snapshot", |
147 | 193 | "megaplan_root", |
148 | 194 | "normalize_text", |
149 | 195 | "now_utc", |
| 196 | + "orphan_plans_root", |
| 197 | + "plan_search_roots", |
150 | 198 | "plans_root", |
| 199 | + "prepare_journal_transaction", |
151 | 200 | "read_json", |
| 201 | + "read_committed_framed_json_records", |
| 202 | + "recover_journal", |
| 203 | + "repo_storage_id", |
152 | 204 | "render_final_md", |
153 | 205 | "save_config", |
154 | 206 | "schemas_root", |
| 207 | + "scrub_stale_staging_files", |
155 | 208 | "sha256_file", |
156 | 209 | "sha256_text", |
157 | 210 | "slugify", |
| 211 | + "write_journal_commit_marker", |
158 | 212 | # phase_runtime |
159 | 213 | "DEFAULT_NON_EXECUTE_TIMEOUT_CAP_SECONDS", |
160 | 214 | "PHASE_RUNTIME_POLICY", |
|
0 commit comments