diff --git a/apis/workflows/v1/job.proto b/apis/workflows/v1/job.proto
index 32bad34..06accf3 100644
--- a/apis/workflows/v1/job.proto
+++ b/apis/workflows/v1/job.proto
@@ -70,8 +70,8 @@ message TaskSummary {
   int64 max_retries = 10;
   // Whether the task has children in the user-visible tree.
   bool has_children = 11;
-  // The ID of the cluster on which the task is scheduled to run.
-  tilebox.v1.ID cluster_id = 12;
+  // The slug of the cluster on which the task is scheduled to run.
+  string cluster_slug = 12;
   // Whether failure of the task is optional, either directly or through an optional ancestor.
   bool optional = 13;
 }
diff --git a/apis/workflows/v1/telemetry.proto b/apis/workflows/v1/telemetry.proto
index 6c6e50e..a967022 100644
--- a/apis/workflows/v1/telemetry.proto
+++ b/apis/workflows/v1/telemetry.proto
@@ -17,6 +17,8 @@ message QueryJobLogsRequest {
   tilebox.v1.Pagination page = 2 [features.field_presence = EXPLICIT];
   // The direction in which to sort log entries. If not specified, defaults to ascending order (oldest entries first).
   tilebox.v1.SortDirection sort_direction = 3;
+  // The ID of the task to query logs for. If not specified, logs for the full job are returned.
+  tilebox.v1.ID task_id = 4 [features.field_presence = EXPLICIT];
 }
 
 // QueryLogsInIntervalRequest is the request message for querying logs in a specific time interval.
@@ -48,6 +50,8 @@ message QueryJobSpansRequest {
   tilebox.v1.Pagination page = 2 [features.field_presence = EXPLICIT];
   // The direction in which to sort log entries. If not specified, defaults to ascending order (oldest entries first).
   tilebox.v1.SortDirection sort_direction = 3;
+  // The ID of the task to query spans for. If not specified, spans for the full job are returned.
+  tilebox.v1.ID task_id = 4 [features.field_presence = EXPLICIT];
 }
 
 // PaginatedSpansData is the response message for paginated log queries. It's a message compatible with LogsData,