Skip to content

Commit 0d9ccef

Browse files
committed
just use the actual variable for send/setevent gob registration
1 parent 311f80b commit 0d9ccef

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

dbos/workflow.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1228,8 +1228,7 @@ func Send[P any](ctx DBOSContext, destinationID string, message P, topic string)
12281228
if c, ok := ctx.(*dbosContext); ok {
12291229
logger = c.logger
12301230
}
1231-
var typedMessage P
1232-
safeGobRegister(typedMessage, logger)
1231+
safeGobRegister(message, logger)
12331232
return ctx.Send(ctx, destinationID, message, topic)
12341233
}
12351234

@@ -1309,8 +1308,7 @@ func SetEvent[P any](ctx DBOSContext, key string, message P) error {
13091308
if c, ok := ctx.(*dbosContext); ok {
13101309
logger = c.logger
13111310
}
1312-
var typedMessage P
1313-
safeGobRegister(typedMessage, logger)
1311+
safeGobRegister(message, logger)
13141312
return ctx.SetEvent(ctx, key, message)
13151313
}
13161314

0 commit comments

Comments
 (0)