Module cf_worker_process

cleanup_case(A, R, CfWorkerState) -> R1::#{atom() => term()}

• A = #{atom() => term()}
• R = #{atom() => term()}
• CfWorkerState = #cf_worker_state{}

do_stagein(A::term(), F::term(), UsrInfo::term()) -> ok | {error, enoent}

do_stageout(A::term(), F::term(), UsrInfo::term()) -> ok | {error, enoent}

error_to_expr(A, Reason, UsrInfo) -> term()

• A = #{atom() => term()}
• Reason = {stagein | stageout, [binary()]} | {run, term()}
• UsrInfo = term()

init(X1::{WrkDir, RepoDir, DataDir}) -> #cf_worker_state{}

• WrkDir = string()
• RepoDir = string()
• DataDir = string()

prepare_case(A::term(), CfWorkerState::term()) -> ok

run(A::term(), UsrInfo::term()) -> {ok, R::term()} | {error, Reason::term()}

stagein_lst(A::term(), UsrInfo::term()) -> [F::term()]

stageout_lst(A::term(), R::term(), UsrInfo::term()) -> [F::term()]

start_link(F, WrkDir, RepoDir, DataDir) -> any()