version 0.1.1

[jfathi]

First major upgrades since 2022! 🎉
We're actively seeking support! Reach out to @WebberTeam or @jfathi.

New Features

Conditional Edges: DAGs can now continue execution along a node-path in case of a parent node's failure! Edge conditions are documented as in the enum webber.Condition, as Success, Failure, or AnyCase. Default edge condition is Success. See: webber.Condition

Retry Nodes: Nodes can now be re-executed multiple times in case of failure. See: DAG.retry_node(n)

Skip Nodes: DAGs can now skip over nodes and continue onto their child/dependent nodes. Before executing, skipped nodes can be pre-registered as either successful or failed executions, enabling diverse opportunities for DAG testing in tandem with conditional execution. See: DAG.skip_node(n)

Trace Exceptions: Trace printouts disabled by default, can be enabled at DAG execution time: DAG.execute(print_exc=True)

Critical Node Paths: Critical Node Paths: DAGs can be reduced to a set of specified nodes and their dependencies. Capability still under development. See: DAG.critical_path(n)

Other Improvements

• Use UUID4 to limit repeating GUIDs.
• Complex xcoms deprecated in favor of Promise model.
• Improved doc-strings, bug squashes.

Known Bugs and Gaps

• STDOUT logging is not guaranteed to correlate to correct node at 3+ concurrent operations.

Project Backlog

• Get/Update Functions for Nodes and Edges
• Expanded support for Jupyter Notebook visualizations
• Edge and Node filtering with Lambda Functions (e.g.: lambda e: e.Condition == condition.OnSuccess).

---

This discussion was created from the release version 0.1.1.