shigoto_executor (shigoto v1.9.10)
View SourceExecutes a single job through the middleware chain with seki resilience. Started by the executor supervisor, reports back to the queue process when done.
Summary
Functions
Execute a job synchronously (for drain_queue).
Run a worker through the exact perform path production uses: deps_results
injection + the middleware chain + perform/1 under Timeout. Returns the raw
worker result (ok | {ok, Result} | {error, _} | {snooze, _}).
Functions
-spec execute_sync(map(), atom(), timeout()) -> ok | {snooze, pos_integer()} | {error, term()}.
Execute a job synchronously (for drain_queue).
-spec run_perform(map(), module(), map(), timeout()) -> ok | {ok, term()} | {error, term()} | {snooze, pos_integer()}.
Run a worker through the exact perform path production uses: deps_results
injection + the middleware chain + perform/1 under Timeout. Returns the raw
worker result (ok | {ok, Result} | {error, _} | {snooze, _}).
Shared by the queue executor, execute_sync/3, and shigoto:perform_job/2,3.
It performs NO persistence, telemetry, retry, or resilience gating — those are the
caller's responsibility. Used by the testing helpers to run a worker with no DB.