schedula: An intelligent function scheduler¶
| release: | 0.1.19 |
|---|---|
| date: | 2018-06-05 13:00:00 |
| repository: | |
| pypi-repo: | |
| docs: | |
| wiki: | |
| download: | |
| keywords: | scheduling, dispatch, dataflow, processing, calculation, dependencies, scientific, engineering, simulink, graph theory |
| developers: |
|
| license: |
What is schedula?¶
Schedula implements a intelligent function scheduler, which selects and executes functions. The order (workflow) is calculated from the provided inputs and the requested outputs. A function is executed when all its dependencies (i.e., inputs, input domain) are satisfied and when at least one of its outputs has to be calculated.
Note
Schedula is performing the runtime selection of the minimum-workflow to be invoked. A workflow describes the overall process - i.e., the order of function execution - and it is defined by a directed acyclic graph (DAG). The minimum-workflow is the DAG where each output is calculated using the shortest path from the provided inputs. The path is calculated on the basis of a weighed directed graph (data-flow diagram) with a modified Dijkstra algorithm.
Installation¶
To install it use (with root privileges):
$ pip install schedula
Or download the last git version and use (with root privileges):
$ python setup.py install
Table of Contents¶
- 1. What is schedula?
- 2. Installation
- 3. Why may I use schedula?
- 4. Very simple example
- 5. Advanced example (circular system)
- 6. Next moves
- 7. API Reference
- 7.1. dispatcher
- 7.1.1. Dispatcher
- 7.1.1.1. __init__
- 7.1.1.2. add_data
- 7.1.1.3. add_dispatcher
- 7.1.1.4. add_from_lists
- 7.1.1.5. add_function
- 7.1.1.6. copy
- 7.1.1.7. copy_structure
- 7.1.1.8. dispatch
- 7.1.1.9. get_node
- 7.1.1.10. get_sub_dsp
- 7.1.1.11. get_sub_dsp_from_workflow
- 7.1.1.12. plot
- 7.1.1.13. search_node_description
- 7.1.1.14. set_data_remote_link
- 7.1.1.15. set_default_value
- 7.1.1.16. shrink_dsp
- 7.1.1.17. web
- 7.1.1.18. data_nodes
- 7.1.1.19. function_nodes
- 7.1.1.20. sub_dsp_nodes
- 7.1.1. Dispatcher
- 7.2. utils
- 7.2.1. alg
- 7.2.2. base
- 7.2.3. cst
- 7.2.4. des
- 7.2.5. drw
- 7.2.5.1. add_header
- 7.2.5.2. autoplot_callback
- 7.2.5.3. autoplot_function
- 7.2.5.4. basic_app
- 7.2.5.5. before_request
- 7.2.5.6. cached_view
- 7.2.5.7. jinja2_format
- 7.2.5.8. render_output
- 7.2.5.9. run_server
- 7.2.5.10. site_view
- 7.2.5.11. uncpath
- 7.2.5.12. update_filenames
- 7.2.5.13. valid_filename
- 7.2.5.14. FolderNode
- 7.2.5.15. Site
- 7.2.5.16. SiteFolder
- 7.2.5.17. SiteIndex
- 7.2.5.18. SiteMap
- 7.2.5.19. SiteNode
- 7.2.6. dsp
- 7.2.6.1. add_function
- 7.2.6.2. are_in_nested_dicts
- 7.2.6.3. bypass
- 7.2.6.4. combine_dicts
- 7.2.6.5. combine_nested_dicts
- 7.2.6.6. get_nested_dicts
- 7.2.6.7. kk_dict
- 7.2.6.8. map_dict
- 7.2.6.9. map_list
- 7.2.6.10. parent_func
- 7.2.6.11. replicate_value
- 7.2.6.12. selector
- 7.2.6.13. stack_nested_keys
- 7.2.6.14. stlp
- 7.2.6.15. summation
- 7.2.6.16. DFun
- 7.2.6.17. DispatchPipe
- 7.2.6.18. NoSub
- 7.2.6.19. SubDispatch
- 7.2.6.20. SubDispatchFunction
- 7.2.6.21. SubDispatchPipe
- 7.2.6.22. add_args
- 7.2.7. exc
- 7.2.8. gen
- 7.2.9. io
- 7.2.10. sol
- 7.2.11. web
- 7.3. ext
- 7.1. dispatcher