Parameter MakePolling.Repo
val enqueue :
Core.Ctx.t ->
job_instance:Queue__.Queue_core.JobInstance.t ->
unit Lwt.tval find_workable : Core.Ctx.t -> Queue__.Queue_core.JobInstance.t list Lwt.tval update :
Core.Ctx.t ->
job_instance:Queue__.Queue_core.JobInstance.t ->
unit Lwt.t