refactor: remove orchestrator/graph.rs re-export shim

Import hm_pipeline_ir types directly instead of going through a
one-line re-export module.

Author: markovejnovic

crates/hm/src/orchestrator/graph.rs

@@ -11,7 +11,6 @@ pub mod cache;
 pub mod docker_client;
 pub mod docker_host_fns;
 pub mod events;
-pub mod graph;
 pub mod output_subscriber;
 pub mod scheduler;
 pub mod source;

crates/hm/src/orchestrator/mod.rs

@@ -43,9 +43,10 @@ use hm_plugin_protocol::{
 use tokio::sync::Mutex;
 use uuid::Uuid;
 
+use hm_pipeline_ir::{EdgeKind, PipelineGraph, Transition};
+
 use crate::error::HmError;
 use crate::orchestrator::docker_client::DockerClient;
-use crate::orchestrator::graph::{EdgeKind, Transition};
 use crate::orchestrator::source::build_archive_bytes;
 use crate::plugin::{PluginRegistry, RegistryConfig};
 
@@ -73,7 +74,7 @@ type StepFuture = futures::future::Shared<BoxFuture<'static, StepOutcome>>;
 /// scheduler-level failure occurs. Non-zero step exit codes are
 /// surfaced via the returned `i32`, not as an Err.
 pub async fn run(
-    graph: crate::orchestrator::graph::Graph,
+    graph: PipelineGraph,
     repo_root: PathBuf,
     parallelism: usize,
     format_name: String,

crates/hm/src/orchestrator/scheduler.rs

@@ -14,13 +14,13 @@
 )]
 
 use daggy::petgraph::visit::IntoNodeReferences;
-use harmont_cli::orchestrator::graph::Graph;
+use hm_pipeline_ir::PipelineGraph;
 
-fn decode(json: &[u8]) -> Graph {
-    serde_json::from_slice::<Graph>(json).unwrap()
+fn decode(json: &[u8]) -> PipelineGraph {
+    serde_json::from_slice::<PipelineGraph>(json).unwrap()
 }
 
-fn find_step<'a>(g: &'a Graph, key: &str) -> &'a hm_pipeline_ir::CommandStep {
+fn find_step<'a>(g: &'a PipelineGraph, key: &str) -> &'a hm_pipeline_ir::CommandStep {
     let dag = g.dag();
     let (_, t) = dag.graph().node_references()
         .find(|(_, t)| t.step.key == key)

crates/hm/tests/default_image_inheritance.rs

@@ -39,7 +39,7 @@ use std::collections::BTreeMap;
 use daggy::petgraph::visit::IntoNodeReferences;
 
 use common::fixtures;
-use harmont_cli::orchestrator::graph::Graph;
+use hm_pipeline_ir::PipelineGraph;
 use harmont_cli::plugin::{PluginRegistry, RegistryConfig};
 use hm_plugin_protocol::{ArchiveId, CacheDecision, ExecutorInput, StepResult};
 use uuid::Uuid;
@@ -85,7 +85,7 @@ async fn runner_field_dispatches_to_named_plugin() {
     .expect("load registry");
 
     // 2. Deserialize the graph directly from JSON — the new wire format.
-    let graph: Graph = serde_json::from_slice(PIPELINE_JSON).expect("parse graph");
+    let graph: PipelineGraph = serde_json::from_slice(PIPELINE_JSON).expect("parse graph");
 
     // Sanity check: the graph must preserve `runner` from the IR.
     // This is the cheap fast-fail; the dispatch check below is the