The horizon.utils.threaded ModuleΒΆ

class horizon.utils.threaded.ThreadedPromise(target=None, args=(), kwargs=None, **_kwargs)[source]

Bases: threading.Thread

propagate_exceptions()[source]
result
run()[source]
horizon.utils.threaded.promise(func)[source]