main.go

package main

import (
    "fmt"
)

type Task struct {
    Name         string
    Dependencies []*Task
    Run          func() error
}

func ExecuteWorkflow(tasks []*Task) {
    visited := make(map[string]bool)
    for _, task := range tasks {
        executeTask(task, visited)
    }
}

func executeTask(task *Task, visited map[string]bool) {
    if visited[task.Name] {
        return
    }

    for _, dep := range task.Dependencies {
        executeTask(dep, visited)
    }

    fmt.Printf("Starting %s...\n", task.Name)
    err := task.Run()
    if err != nil {
        fmt.Printf("Error in %s: %v\n", task.Name, err)
    } else {
        fmt.Printf("Completed %s!\n", task.Name)
    }

    visited[task.Name] = true
}

func main() {
    taskA := &Task{
        Name: "TaskA",
        Run: func() error {
            fmt.Println("Running TaskA")
            return nil
        },
    }

    taskB := &Task{
        Name: "TaskB",
        Dependencies: []*Task{taskA},
        Run: func() error {
            fmt.Println("Running TaskB")
            return nil
        },
    }

    taskC := &Task{
        Name: "TaskC",
        Dependencies: []*Task{taskA},
        Run: func() error {
            fmt.Println("Running TaskC")
            return nil
        },
    }

    taskD := &Task{
        Name: "TaskD",
        Dependencies: []*Task{taskB, taskC},
        Run: func() error {
            fmt.Println("Running TaskD")
            return nil
        },
    }

    ExecuteWorkflow([]*Task{taskD})
}