oc_chat
Loading...
Searching...
No Matches
runner.py File Reference

Go to the source code of this file.

Namespaces

namespace  oc_chat
namespace  oc_chat.registry
namespace  oc_chat.registry.source_migrations
namespace  oc_chat.registry.source_migrations.runner

Functions

None oc_chat.registry.source_migrations.runner._replace (Path src, Path dst)
None oc_chat.registry.source_migrations.runner._fsync ("object" fileobj)
 oc_chat.registry.source_migrations.runner._disk_usage (Path path)
str oc_chat.registry.source_migrations.runner._new_run_id ()
str oc_chat.registry.source_migrations.runner.validate_target_semver (Any raw)
tuple[int,...] oc_chat.registry.source_migrations.runner._version_tuple (str version)
Optional[str] oc_chat.registry.source_migrations.runner._git_status_porcelain (Path root)
bool oc_chat.registry.source_migrations.runner._is_reparse_point (os.stat_result lstat_result)
None oc_chat.registry.source_migrations.runner._path_integrity_guard (Path root, list records)
Path oc_chat.registry.source_migrations.runner._production_package_dir ()
Any oc_chat.registry.source_migrations.runner._import_migration_module (Path path)
list[Any] oc_chat.registry.source_migrations.runner.production_migration_provider ()
list[list[SourceMigration]] oc_chat.registry.source_migrations.runner._find_chains (str start_version, str domain, str target, list[SourceMigration] migrations)
Any oc_chat.registry.source_migrations.runner._run_chain (list[SourceMigration] chain, Any model)
Any oc_chat.registry.source_migrations.runner._terminal_entry (list[SourceMigration] chain, Any model)
type oc_chat.registry.source_migrations.runner._model_class_for (Any scanned)
str oc_chat.registry.source_migrations.runner._sha256 (bytes data)
str oc_chat.registry.source_migrations.runner._record_id (Any model)
None oc_chat.registry.source_migrations.runner._safe_unlink (Path path)
MigrateError oc_chat.registry.source_migrations.runner._wrap_module_failure (Exception exc, list[str] records, Optional[str] raw, Optional[str] src)
dict oc_chat.registry.source_migrations.runner.run_migration (*, Path source_root, Path workspace_root, str target, Callable[[], list[Any]] provider, bool quiet=False)
None oc_chat.registry.source_migrations.runner._refuse_on_unresolved_journal (Path journal_root, Path source_root)
None oc_chat.registry.source_migrations.runner._validate_output_paths (source_root, write_set, entries_by_path, records, raw_hash, src_hash)
 oc_chat.registry.source_migrations.runner._output_path_reason (output_path, rel_path, root_resolved, candidate_rels, seen)
bool oc_chat.registry.source_migrations.runner._is_absolute (str output_path)
Optional[int] oc_chat.registry.source_migrations.runner._file_mode (Path path)
None oc_chat.registry.source_migrations.runner._disk_preflight (source_root, journal_root, header, write_set, candidate_len, candidate_mode, outputs, raw_hash, src_hash)
bool oc_chat.registry.source_migrations.runner._same_volume (Path path_a, Path path_b)
dict oc_chat.registry.source_migrations.runner._success_payload (target, migrated, unchanged, journal_path=None, journal_unresolved=False, hint=None)
list[dict] oc_chat.registry.source_migrations.runner._migrated_list (write_set, outputs, target)
dict oc_chat.registry.source_migrations.runner._write_phase (*, source_root, target, target_journal_dir, header, write_set, outputs, candidate_sha, candidate_mode, unchanged, raw_hash, src_hash)
None oc_chat.registry.source_migrations.runner._finalize_post_write_failure (error, writer, source_root, written, candidate_sha, in_flight, raw_hash, src_hash)
None oc_chat.registry.source_migrations.runner._resolve_after_rollback (writer, error)
tuple oc_chat.registry.source_migrations.runner._rollback (writer, source_root, written, candidate_sha, in_flight)

Variables

 oc_chat.registry.source_migrations.runner._TARGET_SEMVER_RE = re.compile(r"(0|[1-9][0-9]*)\.(0|[1-9][0-9]*)\.(0|[1-9][0-9]*)")
 oc_chat.registry.source_migrations.runner.DISCOVERY_STEM_RE
str oc_chat.registry.source_migrations.runner._JOURNAL_RELATIVE = Path(".option_c") / "orchestration" / "source_migrations" / ".journal"
float oc_chat.registry.source_migrations.runner._DISK_HEADROOM = 1.5