feat: add orchestration output visibility lifecycle

crates/arco-api/openapi.json

@@ -4,8 +4,8 @@
     "title": "Arco API",
     "description": "Arco catalog REST API (M4/M5)",
     "contact": {
-      "name": "Ethan Urbanski",
-      "email": "ethan@daxistech.io"
+      "name": "Daxis",
+      "email": "engineering@daxis.io"
     },
     "license": {
       "name": "Apache-2.0",
@@ -7407,6 +7407,32 @@
             ],
             "description": "Output path."
           },
+          "outputVisibilityState": {
+            "oneOf": [
+              {
+                "type": "null"
+              },
+              {
+                "$ref": "#/components/schemas/TaskOutputVisibilityState",
+                "description": "Output visibility state, when the worker/runtime can report it."
+              }
+            ]
+          },
+          "publishError": {
+            "type": [
+              "string",
+              "null"
+            ],
+            "description": "Publish failure details, if applicable."
+          },
+          "publishedAt": {
+            "type": [
+              "string",
+              "null"
+            ],
+            "format": "date-time",
+            "description": "When output became visible, if applicable."
+          },
           "rowCount": {
             "type": [
               "integer",
@@ -7418,6 +7444,24 @@
           }
         }
       },
+      "TaskOutputVisibilityState": {
+        "type": "string",
+        "description": "Worker-reported output visibility state.",
+        "enum": [
+          "PENDING",
+          "VISIBLE",
+          "FAILED"
+        ]
+      },
+      "TaskOutputVisibilityStateResponse": {
+        "type": "string",
+        "description": "Task output visibility summary.",
+        "enum": [
+          "PENDING",
+          "VISIBLE",
+          "FAILED"
+        ]
+      },
       "TaskRetryAttributionResponse": {
         "type": "object",
         "description": "Retry attribution details for a task.",
@@ -7594,6 +7638,32 @@
             ],
             "description": "Deterministic execution lineage reference for successful materializations."
           },
+          "outputVisibilityState": {
+            "oneOf": [
+              {
+                "type": "null"
+              },
+              {
+                "$ref": "#/components/schemas/TaskOutputVisibilityStateResponse",
+                "description": "Output visibility state for required-output tasks."
+              }
+            ]
+          },
+          "publishError": {
+            "type": [
+              "string",
+              "null"
+            ],
+            "description": "Publish failure details for output visibility failures."
+          },
+          "publishedAt": {
+            "type": [
+              "string",
+              "null"
+            ],
+            "format": "date-time",
+            "description": "When output became visible."
+          },
           "retryAttribution": {
             "oneOf": [
               {

crates/arco-api/src/openapi.rs

@@ -14,7 +14,11 @@ use utoipa::{Modify, OpenApi};
     info(
         title = "Arco API",
         version = env!("CARGO_PKG_VERSION"),
-        description = "Arco catalog REST API (M4/M5)"
+        description = "Arco catalog REST API (M4/M5)",
+        contact(
+            name = "Daxis",
+            email = "engineering@daxis.io"
+        )
     ),
     paths(
         crate::routes::catalogs::create_catalog,
@@ -111,6 +115,7 @@ use utoipa::{Modify, OpenApi};
             crate::routes::orchestration::RunStateResponse,
             crate::routes::orchestration::RunResponse,
             crate::routes::orchestration::TaskSummary,
+            crate::routes::orchestration::TaskOutputVisibilityStateResponse,
             crate::routes::orchestration::TaskStateResponse,
             crate::routes::orchestration::TaskCounts,
             crate::routes::orchestration::ListRunsResponse,
@@ -172,6 +177,7 @@ use utoipa::{Modify, OpenApi};
             crate::routes::tasks::TaskCompletedRequest,
             crate::routes::tasks::TaskCompletedResponse,
             crate::routes::tasks::WorkerOutcome,
+            crate::routes::tasks::TaskOutputVisibilityState,
             crate::routes::tasks::TaskOutput,
             crate::routes::tasks::TaskError,
             crate::routes::tasks::ErrorCategory,