service-flow 0.1.1

service object flow orchestrator

service-flow

A small, simple, and elegant component/function orchestration framework for Python, service-flow enables separation of a functionality into single-responsibility and bite-size functions/service objects, which are testable and reuseable. It further helps with readability and maintainability of the embedding application.

• Implementation
  • flow
    • simple example
    • fork example
  • services
    • example
    • conventions
      • initializaition parameters
      • function parameters
      • return value
• inspiration
• TODOs
• install

Implementation

service-flow has two parts -- a flow and multiple services (Note: the word service here refers to a function, not RESTful services):

flow

a flow is the definition of processing procedure. It is defined as the following:

simple example

stack = Service1() >> \ 
        Service2(*args) >> \ 
        ... 
        ServiceN(**kwargs) 
        
output = stack(input) ## input is a dictionary with all the input parameters as attributes

Python >> operator is overloaded to define the sequeunce of the processing. Service1(), ..., ServiceN() are instances of the services, or functions.

for each processing of the input, service-flow creates a context, a dictionary-like object that serves as input and gather outputs from all the services.

fork example

stack = Service1() >> \ 
        Service2(*args) < \ 
        ('context_var_name', {
            'var_value1': (Service3() >> Service4(**kwargs)),
            'var_value2': (Service5() >> Service4(**kwargs)),
          }
        ) 
        
output = stack(input) ## input is a dictionary with all the input parameters as attributes

Python < operator is overloaded to define a fork in processing. In this example, context_var_name is the name of context key, and var_value1, var_value2 are potential values for forking.

services

A service is the equivalent of a Python function.

example

class InplaceModification(Middleware):
    def __init__(self, increment): # initialization
        self.increment = 1

    def __call__(self, bar: list): # service call 
        return {'bar': [i + self.increment for i in bar]}

conventions

It needs to follow the convention below:

initializaition parameters

parameters that initializes the service and is shared for all the calls to the service.

function parameters

these are used to call a service and have to be existing attributes in the context object.

return value

the return value of a service is optional. If a service does return values:

1. if it is a dictionary, it will add/update the aforementioned processing context.
2. otherwise, the return value is ignored and a warning message is logged.

inspiration

service-flow draws inspiration from the following Ruby projects:

1. Rack
2. Light Service
3. Ruby Middleware

TODOs

install

pip install service-flow