A functional reactive platform used to process time-series streams. Provides support for backtest (simulation) and realtime time-series processing. Using a forward propagation graph with a microtask scheduler for the runtime engine.
Project description
hgraph
A functional reactive programming engine with a Python front-end.
This provides a DSL and runtime to support the computation of results over time, featuring a graph based directed acyclic dependency graph and the concept of time-series properties. The language is function based, and promotes composition to extend behaviour.
Here is a simple example:
from hgraph import graph, run_graph, const
from hgraph.nodes import debug_print
@graph
def main():
a = const(1)
c = a + 2
debug_print("a + 2", c)
run_graph(main)
Results in:
[1970-01-01 00:00:00.000385][1970-01-01 00:00:00.000001] a + 2: 3
See this for more information.
Development
The project is currently configured to make use of Poetry for dependency management. Take a look at the website to see how best to install the tool. Once you have checked out the project, you can install the project for development using the following command:
This is optional, but you can ensure python uses the version of python you require.
poetry env use 3.11
Then use the following command to install the project and it's depenencies:
poetry install
Then you can find the location of the installation using:
poetry env info
PyCharm can make use of poetry to setup
the project.
Run Tests
# No Coverage
poetry run pytest
# Generate Coverage Report
poetry run pytest --cov=your_package_name --cov-report=xml
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.