more accurate job manager type
This commit is contained in:
parent
47ca363b18
commit
3ebcf413c9
|
@ -1211,37 +1211,78 @@
|
||||||
|
|
||||||
(define job-manager-actual
|
(define job-manager-actual
|
||||||
'(Role
|
'(Role
|
||||||
(jm89)
|
(jm)
|
||||||
(Shares (JobManagerAlive))
|
(Shares (JobManagerAlive))
|
||||||
(Reacts
|
(Reacts
|
||||||
(Know (Job (Bind Symbol) (Bind (List- InputTask))))
|
(Know
|
||||||
(Role (during-inner97)
|
(Job
|
||||||
(Reacts OnDataflow
|
(Bind Symbol)
|
||||||
(Role (perform114)
|
(Bind (List (Task Int (U (MapWork String) (ReduceWork Int Int)))))))
|
||||||
(Reacts OnStart
|
(Role
|
||||||
(Role (this-facet123)
|
(during-inner)
|
||||||
(Reacts OnDataflow
|
(Reacts
|
||||||
(Branch
|
OnDataflow
|
||||||
(Effs (Branch (Effs
|
(Role
|
||||||
(Role (this-facet120)
|
(perform)
|
||||||
(Shares (TaskAssignment ID Symbol ConcreteTask))
|
(Reacts
|
||||||
(Reacts (Know (TaskState ID Symbol Int (Bind (U* (Finished TaskResult) Symbol))))
|
OnStart
|
||||||
(Branch (Effs) (Effs)
|
(Role
|
||||||
(Effs (Stop this-facet))
|
(this-facet)
|
||||||
;; TODO - why is there a ρ here?
|
(Reacts
|
||||||
(Effs (Stop perform ρ))))
|
OnDataflow
|
||||||
(Reacts OnStart
|
(Branch
|
||||||
(Role (take-slot121)
|
(Effs
|
||||||
(Reacts (Know (TaskState ID Symbol Int Discard))
|
(Branch
|
||||||
(Stop take-slot))))
|
(Effs
|
||||||
(Reacts (¬Know (TaskManager ID Discard))
|
(Role
|
||||||
(Stop this-facet))))
|
(this-facet)
|
||||||
(Effs)))
|
(Shares
|
||||||
(Effs)))))
|
(TaskAssignment
|
||||||
|
Symbol
|
||||||
|
Symbol
|
||||||
|
(Task
|
||||||
|
Int
|
||||||
|
(U
|
||||||
|
(MapWork String)
|
||||||
|
(ReduceWork (Hash String Int) (Hash String Int))))))
|
||||||
|
(Reacts
|
||||||
|
(Know
|
||||||
|
(TaskState
|
||||||
|
Symbol
|
||||||
|
Symbol
|
||||||
|
Int
|
||||||
|
(Bind (U (Finished (Hash String Int)) Symbol))))
|
||||||
|
(Branch
|
||||||
|
(Effs)
|
||||||
|
(Effs)
|
||||||
|
(Effs (Stop this-facet))
|
||||||
|
(Effs
|
||||||
|
(Stop
|
||||||
|
perform
|
||||||
|
(Branch
|
||||||
|
(Effs
|
||||||
|
(Role
|
||||||
|
(done)
|
||||||
|
(Shares (JobFinished Symbol (Hash String Int)))))
|
||||||
|
(Effs))))))
|
||||||
|
(Reacts
|
||||||
|
OnStart
|
||||||
|
(Role
|
||||||
|
(take-slot)
|
||||||
|
(Reacts
|
||||||
|
(Know (TaskState Symbol Symbol Int Discard))
|
||||||
|
(Stop take-slot))))
|
||||||
|
(Reacts (¬Know (TaskManager Symbol Discard)) (Stop this-facet))))
|
||||||
|
(Effs)))
|
||||||
|
(Effs)))))
|
||||||
(Reacts OnStop)
|
(Reacts OnStop)
|
||||||
(Reacts OnStart)))
|
(Reacts OnStart)))
|
||||||
(Reacts (¬Know (Job Symbol (List- InputTask)))
|
(Reacts
|
||||||
(Stop during-inner))))
|
(¬Know
|
||||||
|
(Job
|
||||||
|
Symbol
|
||||||
|
(List (Task Int (U (MapWork String) (ReduceWork Int Int))))))
|
||||||
|
(Stop during-inner))))
|
||||||
(Reacts (¬Know (TaskManager (Bind Symbol) (Bind Int))))
|
(Reacts (¬Know (TaskManager (Bind Symbol) (Bind Int))))
|
||||||
(Reacts (Know (TaskManager (Bind Symbol) (Bind Int))))))
|
(Reacts (Know (TaskManager (Bind Symbol) (Bind Int))))))
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue