EntropyEngine::Core::Concurrency::GraphExecutionCompletedEvent

EntropyEngine::Core::Concurrency::GraphExecutionCompletedEvent

The finish line - all nodes have reached terminal states. More…

#include <WorkGraphEvents.h>

Inherits from EntropyEngine::Core::Concurrency::WorkGraphEvent

Public Functions

	Name
	GraphExecutionCompletedEvent(const WorkGraph * g, const WorkGraphStats::Snapshot & s)

Public Attributes

	Name
WorkGraphStats::Snapshot	stats Final statistics for the run.

Additional inherited members

Public Functions inherited from EntropyEngine::Core::Concurrency::WorkGraphEvent

	Name
	WorkGraphEvent(const WorkGraph * g)

Public Attributes inherited from EntropyEngine::Core::Concurrency::WorkGraphEvent

	Name
std::chrono::steady_clock::time_point	timestamp When this event was created.
const WorkGraph *	graph Which graph emitted this event.

Detailed Description

struct EntropyEngine::Core::Concurrency::GraphExecutionCompletedEvent;

The finish line - all nodes have reached terminal states.

This fires when the entire graph is done, whether successfully or not. The stats snapshot gives you the complete picture: successes, failures, cancellations, and performance metrics. This is your post-mortem data.

eventBus->subscribe<GraphExecutionCompletedEvent>([](const auto& event) {
    const auto& stats = event.stats;
    LOG_INFO("Workflow complete: {} succeeded, {} failed, {} cancelled",
             stats.completedNodes, stats.failedNodes, stats.cancelledNodes);

    auto seconds = std::chrono::duration_cast<std::chrono::seconds>(
        stats.totalExecutionTime).count();
    LOG_INFO("Total execution time: {}s", seconds);

    if (stats.failedNodes > 0) {
        LOG_ERROR("Workflow had failures!");
    }
});

Public Functions Documentation

function GraphExecutionCompletedEvent

inline GraphExecutionCompletedEvent(
    const WorkGraph * g,
    const WorkGraphStats::Snapshot & s
)

Public Attributes Documentation

variable stats

WorkGraphStats::Snapshot stats;

Final statistics for the run.

---

Updated on 2026-01-26 at 17:14:35 -0500