Skip to content

Commit e526401

Browse files
committed
return q parameters in conductor protocol
1 parent 8902470 commit e526401

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

dbos/conductor_protocol.go

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,9 @@ type listWorkflowsConductorResponseBody struct {
8787
CreatedAt *string `json:"CreatedAt,omitempty"`
8888
UpdatedAt *string `json:"UpdatedAt,omitempty"`
8989
QueueName *string `json:"QueueName,omitempty"`
90+
QueuePartitionKey *string `json:"QueuePartitionKey,omitempty"`
91+
DeduplicationID *string `json:"DeduplicationID,omitempty"`
92+
Priority *int `json:"Priority,omitempty"`
9093
ApplicationVersion *string `json:"ApplicationVersion,omitempty"`
9194
ExecutorID *string `json:"ExecutorID,omitempty"`
9295
}
@@ -167,6 +170,21 @@ func formatListWorkflowsResponseBody(wf WorkflowStatus) listWorkflowsConductorRe
167170
output.QueueName = &wf.QueueName
168171
}
169172

173+
// Copy queue partition key
174+
if wf.QueuePartitionKey != "" {
175+
output.QueuePartitionKey = &wf.QueuePartitionKey
176+
}
177+
178+
// Copy deduplication ID
179+
if wf.DeduplicationID != "" {
180+
output.DeduplicationID = &wf.DeduplicationID
181+
}
182+
183+
// Copy priority
184+
if wf.Priority != 0 {
185+
output.Priority = &wf.Priority
186+
}
187+
170188
// Copy application version
171189
if wf.ApplicationVersion != "" {
172190
output.ApplicationVersion = &wf.ApplicationVersion

0 commit comments

Comments
 (0)