Function workflow_dag_demo

preswald/tutorial/hello.py:249–302

()

# --- WORKFLOW DAG COMPONENT ---
@workflow.atom()
def workflow_dag_demo():
    text("## 8. Visualizing Workflow Dependencies with `workflow_dag()`")
    text(
        """
The `workflow_dag()` function renders a Directed Acyclic Graph (DAG) to visualize task dependencies in your workflow.
"""
    )

    # Create a demo workflow for visualization
    demo_workflow = Workflow()

    @demo_workflow.atom()
    def demo_load_data():
        return get_df("sample_csv")

    @demo_workflow.atom(dependencies=["demo_load_data"])
    def demo_clean_data(demo_load_data):
        return demo_load_data.dropna()

    @demo_workflow.atom(dependencies=["demo_clean_data"])
    def demo_analyze_data(demo_clean_data):
        return demo_clean_data.describe()

    # Execute the demo workflow
    demo_workflow.execute()

    # Render the workflow DAG
    workflow_dag(demo_workflow, title="Sample Workflow Dependency Graph")

    text(
        """
The `workflow_dag()` component helps visualize dependencies and relationships within workflows.
**Example:**
```python
from preswald import workflow_dag, Workflow
workflow = Workflow()
@workflow.atom()
def load_data():
    return get_df("sample_csv")
@workflow.atom(dependencies=['load_data'])
def clean_data(load_data):
    return load_data.dropna()
@workflow.atom(dependencies=['clean_data'])
def analyze_data(clean_data):
    return clean_data.describe()
workflow.execute()
workflow_dag(workflow, title="Workflow Dependency Graph")
```
**Key Features:**
- **Visualize Dependencies:** Clearly see how tasks are interconnected.
- **Interactive Exploration:** Zoom, pan, and hover over nodes for details.
- **Customizable Titles:** Make your DAGs more descriptive and easy to understand.
"""
    )


# --- WORKFLOW ANALYZER COMPONENT ---