Module exec 

Physical-plan wrapper that emits COMPLETE / FAIL at end of execution.

crate::rule::OpenLineageQueryPlanner emits START at plan time and carries a COMPLETE template through the plan in a crate::rule::LineageMarker; crate::rule::LineageExtensionPlanner lowers that marker into an OpenLineageExec at the physical root. This node observes the result streams and emits exactly one terminal event once every output partition has finished:

• COMPLETE when all partitions drain successfully;
• FAIL (with an errorMessage run facet) if any partition yields an error or is dropped before its stream is exhausted (e.g. a cancelled query).

Completion is tracked with a Drop-based guard so cancellation is handled without special-casing, and the terminal event fires under the same runId the START used.

Structs

OpenLineageExec

Wraps the root physical plan, emitting a terminal lineage event when execution finishes.