Skip to main content

The dag-modelling package is a python implementation of the dataflow programming with the lazy graph evaluation.

Project description

Summary

python pipeline coverage report

The DAGModelling software is a python implementation of the dataflow programming with the lazy graph evaluation approach.

Main goals:

  • Lazy evaluated directed acyclic graph;
  • Concise connection syntax;
  • Plotting with graphviz;
  • Flexibility. The goal of DAG-Modelling is not to be efficient, but rather flexible.

The framework is intented to be used for the statistical analysis of the data of JUNO and Daya Bay neutrino oscillation experiments.

Installation

For users (recommended)

For regular use, it's best to install the latest version of the project that's available on PyPi:

pip install dag-modelling

For developers

We recommend that developers install the package locally in editable mode:

git clone https://github.com/dagflow-team/dag-modelling.git
cd dag-modelling
pip install -e .

This way, the system will track all the changes made to the source files. This means that developers won't need to reinstall the package or set environment variables, even when a branch is changed.

Example

For example, let's consider a sum of three input nodes and then a product of the result with another array.

from numpy import arange

from dag_modelling.core.graph import Graph
from dag_modelling.plot.graphviz import savegraph
from dag_modelling.lib.common import Array
from dag_modelling.lib.arithmetic import Sum, Product

# Define a source data
array = arange(3, dtype="d")

# Check predefined Array, Sum and Product
with Graph(debug=debug) as graph:
    # Define nodes
    (in1, in2, in3, in4) = (Array(name, array) for name in ("n1", "n2", "n3", "n4"))
    s = Sum("sum")
    m = Product("product")

    # Connect nodes
    (in1, in2, in3) >> s
    (in4, s) >> m
    graph.close()

    print("Result:", m.outputs["result"].data) # must print [0. 3. 12.]
    savegraph(graph, "dagmodelling_example_1a.png")

The printed result must be [0. 3. 12.], and the created image looks as

For more examples see example/example.py or tests.

Repositories and additional modules

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

dag_modelling-0.12.tar.gz (130.0 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

dag_modelling-0.12-py3-none-any.whl (192.8 kB view details)

Uploaded Python 3

File details

Details for the file dag_modelling-0.12.tar.gz.

File metadata

  • Download URL: dag_modelling-0.12.tar.gz
  • Upload date:
  • Size: 130.0 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/2.1.3 CPython/3.13.5 Linux/6.15.5-arch1-1

File hashes

Hashes for dag_modelling-0.12.tar.gz
Algorithm Hash digest
SHA256 ad09dda96a5a192df58b5fbb749ec4461f131435d75b7924da3d644f63b95282
MD5 0c7a35730909a1c1fa79a948a73ffab9
BLAKE2b-256 b8c6c055a1451f8078188dff52b8450b06baf195cc21cee8f149e8c3a1803e5f

See more details on using hashes here.

File details

Details for the file dag_modelling-0.12-py3-none-any.whl.

File metadata

  • Download URL: dag_modelling-0.12-py3-none-any.whl
  • Upload date:
  • Size: 192.8 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/2.1.3 CPython/3.13.5 Linux/6.15.5-arch1-1

File hashes

Hashes for dag_modelling-0.12-py3-none-any.whl
Algorithm Hash digest
SHA256 a28ce5892fe906843976142a0ed5a71820f3679ca7436dca30ef8ddefd2a1934
MD5 e714bb9c04ed84d0fa5e001ddc97f02c
BLAKE2b-256 299149e7d75f742998e82778f20a51d5a3a8dc10c853bd34f9f56f2c58f0cddf

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page