feat: Add workload_id to WorkloadStartRequest proto

crates/wash-runtime/src/washlet/mod.rs

@@ -298,6 +298,11 @@ async fn workload_start(
         anyhow::bail!("workload is required");
     };
 
+    let workload_id = req.workload_id.clone();
+    if workload_id.is_empty() {
+        anyhow::bail!("workload_id is required");
+    }
+
     let (components, host_interfaces) = if let Some(wit_world) = wit_world {
         let mut pulled_components = Vec::with_capacity(wit_world.components.len());
         for component in &wit_world.components {
@@ -307,7 +312,7 @@ async fn workload_start(
                 Err(e) => {
                     return Ok(types::v2::WorkloadStartResponse {
                         workload_status: Some(types::v2::WorkloadStatus {
-                            workload_id: "".into(),
+                            workload_id: workload_id.clone(),
                             workload_state: types::v2::WorkloadState::Error.into(),
                             message: format!(
                                 "failed to pull component image {}: {}",
@@ -348,7 +353,7 @@ async fn workload_start(
             Err(e) => {
                 return Ok(types::v2::WorkloadStartResponse {
                     workload_status: Some(types::v2::WorkloadStatus {
-                        workload_id: "".into(),
+                        workload_id: workload_id.clone(),
                         workload_state: types::v2::WorkloadState::Error.into(),
                         message: format!("failed to pull service image {}: {}", service.image, e),
                     }),
@@ -371,7 +376,7 @@ async fn workload_start(
     let volumes = volumes.into_iter().map(Into::into).collect();
 
     let request = crate::types::WorkloadStartRequest {
-        workload_id: uuid::Uuid::new_v4().to_string(),
+        workload_id: workload_id.clone(),
         workload: crate::types::Workload {
             namespace,
             name,
@@ -384,7 +389,7 @@ async fn workload_start(
     };
 
     info!(
-        worload_id=?request.workload_id,
+        worload_id=?workload_id,
         namespace=?request.workload.namespace,
         name=?request.workload.name,
         "Starting workload");

proto/docs/index.html

@@ -1255,6 +1255,13 @@ <h3 id="wasmcloud.runtime.v2.WorkloadStartRequest">WorkloadStartRequest</h3>
                   <td><p> </p></td>
                 </tr>
 
+                <tr>
+                  <td>workload_id</td>
+                  <td><a href="#string">string</a></td>
+                  <td></td>
+                  <td><p> </p></td>
+                </tr>
+
             </tbody>
           </table>
 

proto/wasmcloud/runtime/v2/workload_service.proto

@@ -13,6 +13,7 @@ service WorkloadService {
 
 message WorkloadStartRequest {
   Workload workload = 1;
+  string workload_id = 2;
 }
 
 message WorkloadStatus {

runtime-operator/internal/controller/runtime/workload_controller.go

@@ -262,6 +262,7 @@ func (r *WorkloadReconciler) reconcilePlacement(ctx context.Context, workload *r
 	}
 
 	req := &runtimev2.WorkloadStartRequest{
+		WorkloadId: string(workload.GetUID()),
 		Workload: &runtimev2.Workload{
 			Namespace:   workload.Namespace,
 			Name:        workload.Name,