testing to see if this fixes failure in ci
This commit is contained in:
parent
8806166a26
commit
a180815ab3
|
@ -90,13 +90,13 @@ proc start*(machine: Machine, initialState: State) =
|
||||||
machine.scheduled = newAsyncQueue[Event]()
|
machine.scheduled = newAsyncQueue[Event]()
|
||||||
|
|
||||||
machine.started = true
|
machine.started = true
|
||||||
machine.scheduler()
|
try:
|
||||||
.track(machine)
|
discard machine.scheduler().track(machine)
|
||||||
.cancelled(proc() = trace("machine.scheduler cancelled, swallowing"))
|
machine.schedule(Event.transition(machine.state, initialState))
|
||||||
.catch((err: ref CatchableError) =>
|
except CancelledError as e:
|
||||||
error("Error in scheduler", error = err.msg)
|
discard
|
||||||
)
|
except CatchableError as e:
|
||||||
machine.schedule(Event.transition(machine.state, initialState))
|
error("Error in scheduler", error = e.msg)
|
||||||
|
|
||||||
proc stop*(machine: Machine) {.async.} =
|
proc stop*(machine: Machine) {.async.} =
|
||||||
if not machine.started:
|
if not machine.started:
|
||||||
|
|
Loading…
Reference in New Issue