Skip to content

Commit 25cfc49

Browse files
committed
nit
1 parent 8515031 commit 25cfc49

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

dbos/conductor.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,7 @@ func (c *Conductor) handleMessage(data []byte) error {
313313
return c.handleRetentionRequest(data, base.RequestID)
314314
default:
315315
c.logger.Warn("Unknown message type", "type", base.Type)
316-
return c.sendErrorResponse(base.RequestID, base.Type, "Unknown message type")
316+
return c.handleUnknownMessageType(base.RequestID, base.Type, "Unknown message type")
317317
}
318318
}
319319

@@ -881,8 +881,8 @@ func (c *Conductor) handleExistPendingWorkflowsRequest(data []byte, requestID st
881881
return c.sendResponse(response, "exist pending workflows response")
882882
}
883883

884-
// sendErrorResponse sends an error response for unknown message types
885-
func (c *Conductor) sendErrorResponse(requestID string, msgType messageType, errorMsg string) error {
884+
// handleUnknownMessageType sends an error response for unknown message types
885+
func (c *Conductor) handleUnknownMessageType(requestID string, msgType messageType, errorMsg string) error {
886886
if c.conn == nil {
887887
return fmt.Errorf("no connection")
888888
}

0 commit comments

Comments
 (0)