mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2025-12-16 22:35:11 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix: panic

Browse Source
This commit is contained in:
mrkaye97
2025-10-10 15:25:41 -04:00
parent 36f425f3c1
commit c0adccf2ea
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
internal/services/controllers/v1/task/controller.go
View File

@@ -792,11 +792,12 @@ func (tc *TasksControllerImpl) handleCancelTasks(ctx context.Context, tenantId s
for _, msg := range msgs {
for _, task := range msg.Tasks {
pubPayloads = append(pubPayloads, tasktypes.CancelledTaskPayload{
TaskId: task.Id,
InsertedAt: task.InsertedAt,
RetryCount: task.RetryCount,
EventType: sqlcv1.V1EventTypeOlapCANCELLED,
ShouldNotify: true,
TaskId: task.Id,
InsertedAt: task.InsertedAt,
RetryCount: task.RetryCount,
EventType: sqlcv1.V1EventTypeOlapCANCELLED,
ShouldNotify: true,
EventExternalId: uuid.NewString(),
})
}
}