electrolyt.run¶

Attributes¶

`logger`
`STATUS`

Classes¶

`ElectrolytJob`	An electrolyt Job.
`ElectrolytJobFactory`

Module Contents¶

electrolyt.run.logger¶

electrolyt.run.STATUS¶

class electrolyt.run.ElectrolytJob(uid: str, data: e3.anod.action.Action, notify_end: collections.abc.Callable, spec_repo: e3.anod.loader.AnodSpecRepository, sandbox: e3.anod.sandbox.SandBox, store: e3.store.backends.base.Store, force_status: e3.anod.status.ReturnValue = STATUS.unknown, dry_run: bool = False)¶

Bases: e3.job.Job

An electrolyt Job.

Variables:

sandbox (e3.anod.sandbox.SandBox) – The sandbox where to run the electrolyt job.
force_status (e3.anod.status.ReturnValue) – Set the status of the job.
dry_run (bool) – If True report kind of action without execution.
store (e3.store.backends.base.Store) – The store backend for accessing source and binary packages.

__status¶

sandbox¶

spec_repo¶

dry_run = False¶

store¶

run() → None¶

property status: e3.anod.status.ReturnValue¶: See Job.status’ description.

run_anod_primitive(primitive: str) → None¶: Run an anod primitive after setting up the sandbox.

do_build() → None¶: Run anod build primitive.

do_install() → None¶: Run anod install primitive.

do_test() → None¶: Run anod test primitive.

do_checkout() → None¶: Get sources from vcs to sandbox vcs_dir.

do_createsource() → None¶: Prepare src from vcs to cache using sourcebuilders.

do_getsource() → None¶

action_item from an intermediate node.

This action should return success status so do_install source can procede.

do_installsource() → None¶: Install the source from tmp/cache to build_space/src.

do_uploadbinarycomponent() → None¶: Upload a binary component.

do_uploadsource() → None¶: Upload a binary component.

do_root() → None¶: Express the final result of the exec.

class electrolyt.run.ElectrolytJobFactory(sandbox: e3.anod.sandbox.SandBox, asr: e3.anod.loader.AnodSpecRepository, store: e3.store.backends.base.Store, dry_run: bool = False)¶

job_status: dict[str, e3.anod.status.ReturnValue]¶

sandbox¶

asr¶

dry_run = False¶

store¶

get_job(uid: str, data: e3.anod.action.Action, predecessors: frozenset[str], notify_end: collections.abc.Callable) → ElectrolytJob¶

collect(job: e3.job.Job) → Literal[False]¶: Return False as the job is never requeued.

run(action_list: e3.collection.dag.DAG) → None¶