dagio

library0.0.2pypypi✓ verified 81d ago

A Python package for running directed acyclic graphs (DAGs) of asynchronous I/O operations. Current version 0.0.2 (pre-release). Allows decorating functions to define dependencies and execute them concurrently when possible.

workflow data

pip install dagio

github ↗package ↗

INSTALL

IMPORT

SIG · DAGIO

dagio

workflowpythonv0.0.2

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

depends

✓ from dagio import depends

✗ from dagio import DAG

run_async

✓ from dagio import run_async

run_async_decorator

✓ from dagio import run_async_decorator

Create a DAG with two nodes, where 'fetch_b' depends on 'fetch_a', and run the graph asynchronously.

import asyncio from dagio import DAG, run_async def fetch(url): # Simulate I/O return url async def main(): dag = DAG() dag.add_node('fetch_a', fetch, kwargs={'url': 'https://a.com'}) dag.add_node('fetch_b', fetch, kwargs={'url': 'https://b.com'}, dependencies=['fetch_a']) results = await dag.run() print(results) asyncio.run(main())

Debug

Known issues

gotchaVersion 0.0.2 is pre-release; API may change without notice. Not recommended for production.

fix

Pin to exact version and test thoroughly before upgrading.

affects: all

gotchaDAG nodes must be callables; if you pass a non-callable, it will raise an error.

fix

Ensure every node is a function or callable object.

affects: all

deprecatedThe `run_async` decorator is experimental; its behavior may change in future versions.

fix

Avoid relying on internals; use asyncio directly if needed.

affects: >=0.0.2

Upgrade

Version history

0.0.2latest on PyPI · released Oct 18, 2021

Audit

Dependencies

No dependency data recorded yet.

Agent activity

23 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/brendanhasz/dagio ↗

packagehttps://pypi.org/project/dagio/ ↗