@@ -264,9 +264,10 @@ func TestNexusSyncOperation(t *testing.T) {
264264 t .Run ("fmt-errorf" , func (t * testing.T ) {
265265 tc .metricsHandler .Clear ()
266266 _ , err := nexus .ExecuteOperation (ctx , nc , syncOp , "fmt-errorf" , nexus.ExecuteOperationOptions {})
267- var unexpectedResponseErr * nexus.UnexpectedResponseError
268- require .ErrorAs (t , err , & unexpectedResponseErr )
269- require .Contains (t , unexpectedResponseErr .Message , `"500 Internal Server Error": arbitrary error message` )
267+ var handlerErr * nexus.HandlerError
268+ require .ErrorAs (t , err , & handlerErr )
269+ require .Equal (t , nexus .HandlerErrorTypeInternal , handlerErr .Type )
270+ require .Contains (t , handlerErr .Failure .Message , "arbitrary error message" )
270271
271272 require .EventuallyWithT (t , func (t * assert.CollectT ) {
272273 tc .requireTimer (t , metrics .NexusTaskEndToEndLatency , service .Name , syncOp .Name ())
@@ -278,10 +279,10 @@ func TestNexusSyncOperation(t *testing.T) {
278279
279280 t .Run ("handlererror" , func (t * testing.T ) {
280281 _ , err := nexus .ExecuteOperation (ctx , nc , syncOp , "handlererror" , nexus.ExecuteOperationOptions {})
281- var unexpectedResponseErr * nexus.UnexpectedResponseError
282- require .ErrorAs (t , err , & unexpectedResponseErr )
283- require .Equal (t , http . StatusBadRequest , unexpectedResponseErr . Response . StatusCode )
284- require .Contains (t , unexpectedResponseErr . Message , `"400 Bad Request": handlererror`
282+ var handlerErr * nexus.HandlerError
283+ require .ErrorAs (t , err , & handlerErr )
284+ require .Equal (t , nexus . HandlerErrorTypeBadRequest , handlerErr . Type )
285+ require .Contains (t , handlerErr . Failure . Message , " handlererror"
285286
286287 require .EventuallyWithT (t , func (t * assert.CollectT ) {
287288 tc .requireTimer (t , metrics .NexusTaskEndToEndLatency , service .Name , syncOp .Name ())
@@ -293,10 +294,10 @@ func TestNexusSyncOperation(t *testing.T) {
293294
294295 t .Run ("already-started" , func (t * testing.T ) {
295296 _ , err := nexus .ExecuteOperation (ctx , nc , syncOp , "already-started" , nexus.ExecuteOperationOptions {})
296- var unexpectedResponseErr * nexus.UnexpectedResponseError
297- require .ErrorAs (t , err , & unexpectedResponseErr )
298- require .Equal (t , http . StatusBadRequest , unexpectedResponseErr . Response . StatusCode )
299- require .Contains (t , unexpectedResponseErr . Message , `"400 Bad Request": faking workflow already started`
297+ var handlerErr * nexus.HandlerError
298+ require .ErrorAs (t , err , & handlerErr )
299+ require .Equal (t , nexus . HandlerErrorTypeBadRequest , handlerErr . Type )
300+ require .Contains (t , handlerErr . Failure . Message , " faking workflow already started"
300301
301302 require .EventuallyWithT (t , func (t * assert.CollectT ) {
302303 tc .requireTimer (t , metrics .NexusTaskEndToEndLatency , service .Name , syncOp .Name ())
@@ -308,10 +309,10 @@ func TestNexusSyncOperation(t *testing.T) {
308309
309310 t .Run ("retryable-application-error" , func (t * testing.T ) {
310311 _ , err := nexus .ExecuteOperation (ctx , nc , syncOp , "retryable-application-error" , nexus.ExecuteOperationOptions {})
311- var unexpectedResponseErr * nexus.UnexpectedResponseError
312- require .ErrorAs (t , err , & unexpectedResponseErr )
313- require .Equal (t , http . StatusInternalServerError , unexpectedResponseErr . Response . StatusCode )
314- require .Contains (t , unexpectedResponseErr . Message , `"500 Internal Server Error": fake app error for test`
312+ var handlerErr * nexus.HandlerError
313+ require .ErrorAs (t , err , & handlerErr )
314+ require .Equal (t , nexus . HandlerErrorTypeInternal , handlerErr . Type )
315+ require .Contains (t , handlerErr . Failure . Message , " fake app error for test"
315316
316317 require .EventuallyWithT (t , func (t * assert.CollectT ) {
317318 tc .requireTimer (t , metrics .NexusTaskEndToEndLatency , service .Name , syncOp .Name ())
@@ -323,10 +324,10 @@ func TestNexusSyncOperation(t *testing.T) {
323324
324325 t .Run ("non-retryable-application-error" , func (t * testing.T ) {
325326 _ , err := nexus .ExecuteOperation (ctx , nc , syncOp , "non-retryable-application-error" , nexus.ExecuteOperationOptions {})
326- var unexpectedResponseErr * nexus.UnexpectedResponseError
327- require .ErrorAs (t , err , & unexpectedResponseErr )
328- require .Equal (t , http . StatusBadRequest , unexpectedResponseErr . Response . StatusCode )
329- require .Contains (t , unexpectedResponseErr . Message , `"400 Bad Request": fake app error for test`
327+ var handlerErr * nexus.HandlerError
328+ require .ErrorAs (t , err , & handlerErr )
329+ require .Equal (t , nexus . HandlerErrorTypeBadRequest , handlerErr . Type )
330+ require .Contains (t , handlerErr . Failure . Message , " fake app error for test"
330331
331332 require .EventuallyWithT (t , func (t * assert.CollectT ) {
332333 tc .requireTimer (t , metrics .NexusTaskEndToEndLatency , service .Name , syncOp .Name ())
@@ -338,10 +339,10 @@ func TestNexusSyncOperation(t *testing.T) {
338339
339340 t .Run ("panic" , func (t * testing.T ) {
340341 _ , err := nexus .ExecuteOperation (ctx , nc , syncOp , "panic" , nexus.ExecuteOperationOptions {})
341- var unexpectedResponseErr * nexus.UnexpectedResponseError
342- require .ErrorAs (t , err , & unexpectedResponseErr )
343- require .Equal (t , 500 , unexpectedResponseErr . Response . StatusCode )
344- require .Contains (t , unexpectedResponseErr .Message , "panic: panic requested" )
342+ var handlerErr * nexus.HandlerError
343+ require .ErrorAs (t , err , & handlerErr )
344+ require .Equal (t , nexus . HandlerErrorTypeInternal , handlerErr . Type )
345+ require .Contains (t , handlerErr . Failure .Message , "panic: panic requested" )
345346
346347 require .EventuallyWithT (t , func (t * assert.CollectT ) {
347348 tc .requireTimer (t , metrics .NexusTaskEndToEndLatency , service .Name , syncOp .Name ())
0 commit comments