coder
diff --git a/‎agent/proto/agent.pb.go
+72-60 b/‎agent/proto/agent.pb.go
+72-60
diff --git a/‎agent/proto/agent.proto
+3-1 b/‎agent/proto/agent.proto
+3-1
diff --git a/‎agent/proto/agent_drpc.pb.go
+1-1 b/‎agent/proto/agent_drpc.pb.go
+1-1
diff --git a/‎coderd/agentapi/logs.go
+2-2 b/‎coderd/agentapi/logs.go
+2-2
diff --git a/‎coderd/agentapi/logs_test.go
+6-5 b/‎coderd/agentapi/logs_test.go
+6-5
@@ -247,7 +247,9 @@ message BatchCreateLogsRequest {
 	repeated Log logs = 2;
 }
 
-message BatchCreateLogsResponse {}
+message BatchCreateLogsResponse {
+	bool log_limit_exceeded = 1;
+}
 
 service Agent {
 	rpc GetManifest(GetManifestRequest) returns (Manifest);
 
@@ -37,7 +37,7 @@ func (a *LogsAPI) BatchCreateLogs(ctx context.Context, req *agentproto.BatchCrea
 		return nil, err
 	}
 	if workspaceAgent.LogsOverflowed {
-		return nil, xerrors.New("workspace agent logs overflowed")
+		return &agentproto.BatchCreateLogsResponse{LogLimitExceeded: true}, nil
 	}
 
 	if len(req.Logs) == 0 {
@@ -128,7 +128,7 @@ func (a *LogsAPI) BatchCreateLogs(ctx context.Context, req *agentproto.BatchCrea
 				return nil, xerrors.Errorf("publish workspace update: %w", err)
 			}
 		}
-		return nil, xerrors.New("workspace agent log limit exceeded")
+		return &agentproto.BatchCreateLogsResponse{LogLimitExceeded: true}, nil
 	}
 
 	// Publish by the lowest log ID inserted so the log stream will fetch
 
@@ -215,9 +215,9 @@ func TestBatchCreateLogs(t *testing.T) {
 			LogSourceId: logSource.ID[:],
 			Logs:        []*agentproto.Log{},
 		})
-		require.Error(t, err)
-		require.ErrorContains(t, err, "workspace agent logs overflowed")
-		require.Nil(t, resp)
+		require.NoError(t, err)
+		require.NotNil(t, resp)
+		require.True(t, resp.LogLimitExceeded)
 		require.False(t, publishWorkspaceUpdateCalled)
 		require.False(t, publishWorkspaceAgentLogsUpdateCalled)
 	})
@@ -419,8 +419,9 @@ func TestBatchCreateLogs(t *testing.T) {
 				},
 			},
 		})
-		require.Error(t, err)
-		require.Nil(t, resp)
+		require.NoError(t, err)
+		require.NotNil(t, resp)
+		require.True(t, resp.LogLimitExceeded)
 		require.True(t, publishWorkspaceUpdateCalled)
 		require.False(t, publishWorkspaceAgentLogsUpdateCalled)
 	})
Original file line number	Diff line number	Diff line change
`@@ -247,7 +247,9 @@ message BatchCreateLogsRequest {`
`247`	`247`	`repeated Log logs = 2;`
`248`	`248`	`}`
`249`	`249`
`250`		`-message BatchCreateLogsResponse {}`
	`250`	`+message BatchCreateLogsResponse {`
	`251`	`+ bool log_limit_exceeded = 1;`
	`252`	`+}`
`251`	`253`
`252`	`254`	`service Agent {`
`253`	`255`	`rpc GetManifest(GetManifestRequest) returns (Manifest);`
Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ func (a LogsAPI) BatchCreateLogs(ctx context.Context, req agentproto.BatchCrea`
`37`	`37`	`return nil, err`
`38`	`38`	`}`
`39`	`39`	`if workspaceAgent.LogsOverflowed {`
`40`		`- return nil, xerrors.New("workspace agent logs overflowed")`
	`40`	`+ return &agentproto.BatchCreateLogsResponse{LogLimitExceeded: true}, nil`
`41`	`41`	`}`
`42`	`42`
`43`	`43`	`if len(req.Logs) == 0 {`
`@@ -128,7 +128,7 @@ func (a LogsAPI) BatchCreateLogs(ctx context.Context, req agentproto.BatchCrea`
`128`	`128`	`return nil, xerrors.Errorf("publish workspace update: %w", err)`
`129`	`129`	`}`
`130`	`130`	`}`
`131`		`- return nil, xerrors.New("workspace agent log limit exceeded")`
	`131`	`+ return &agentproto.BatchCreateLogsResponse{LogLimitExceeded: true}, nil`
`132`	`132`	`}`
`133`	`133`
`134`	`134`	`// Publish by the lowest log ID inserted so the log stream will fetch`