Skip to content
This repository was archived by the owner on May 15, 2025. It is now read-only.

Repository files navigation

microcosm_daemon

Asynchronous workers using a state machine.

Circle CI

Conventions

  • A state machine calls a single-argument worker function in a loop:

    def func(graph):
        pass
    
    state_machine = StateMachine(graph, func)
    state_machine.run()
    
  • A worker function can return another callable to cause a state transition:

    def next_func(graph):
        pass
    
    def func(graph):
        return next_func
    
  • A worker function can raise SleepNow to cause the state machine to sleep before processing itself again:

    def func(graph):
        raise SleepNow
    
  • A worker function can raise an exception. By default, all exceptions except FatalError are swallowed by the state machine's error handler although the state machine can be made to fail fast by configuring the error policy to be strict.

Version 2.0.0

Version 2.0.0 is a breaking change and requires Flask>=2 and markupsafe>=2.1

About

No description or website provided.

Topics

Resources

Stars

0 stars

Watchers

1 watching

Forks

Releases

Packages

Used by

Contributors

Languages