Skip to content

Commit 4a49f12

Browse files
mrkaye97mrkaye97
committed
fix: refs
1 parent 116625b commit 4a49f12

File tree

14 files changed

+187
-187
lines changed

14 files changed

+187
-187
lines changed

‎api/v1/server/handlers/v2/tasks/get.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,11 @@ import (
55

66
"github.com/hatchet-dev/hatchet/api/v1/server/oas/gen"
77
"github.com/hatchet-dev/hatchet/api/v1/server/oas/transformers/v2"
8-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
8+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
99
)
1010

1111
func (t *TasksService) V2TaskGet(ctx echo.Context, request gen.V2TaskGetRequestObject) (gen.V2TaskGetResponseObject, error) {
12-
task := ctx.Get("task").(*timescalev2.V2TasksOlap)
12+
task := ctx.Get("task").(*olapv2.V2TasksOlap)
1313

1414
taskWithData, err := t.config.EngineRepository.OLAP().ReadTaskRunData(ctx.Request().Context(), task.TenantID, task.ID, task.InsertedAt)
1515

‎api/v1/server/handlers/v2/tasks/get_point_metrics.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ import (
99
"github.com/hatchet-dev/hatchet/api/v1/server/oas/apierrors"
1010
"github.com/hatchet-dev/hatchet/api/v1/server/oas/gen"
1111
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/db"
12-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
12+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
1313
)
1414

1515
func (t *TasksService) V2TaskGetPointMetrics(ctx echo.Context, request gen.V2TaskGetPointMetricsRequestObject) (gen.V2TaskGetPointMetricsResponseObject, error) {
@@ -73,7 +73,7 @@ type WorkflowRunEventsMetrics struct {
7373
Results *[]gen.V2TaskPointMetric `json:"results,omitempty"`
7474
}
7575

76-
func convertToGenMetrics(metrics []*timescalev2.GetTaskPointMetricsRow) []gen.V2TaskPointMetric {
76+
func convertToGenMetrics(metrics []*olapv2.GetTaskPointMetricsRow) []gen.V2TaskPointMetric {
7777
converted := make([]gen.V2TaskPointMetric, len(metrics))
7878

7979
for i, metric := range metrics {

‎api/v1/server/handlers/v2/tasks/list_events.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,12 +7,12 @@ import (
77
"github.com/hatchet-dev/hatchet/api/v1/server/oas/transformers/v2"
88
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/db"
99
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
10-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
10+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
1111
)
1212

1313
func (t *TasksService) V2TaskEventList(ctx echo.Context, request gen.V2TaskEventListRequestObject) (gen.V2TaskEventListResponseObject, error) {
1414
tenant := ctx.Get("tenant").(*db.TenantModel)
15-
task := ctx.Get("task").(*timescalev2.V2TasksOlap)
15+
task := ctx.Get("task").(*olapv2.V2TasksOlap)
1616

1717
taskRunEvents, err := t.config.EngineRepository.OLAP().ListTaskRunEvents(ctx.Request().Context(), tenant.ID, task.ID, task.InsertedAt, *request.Params.Limit, *request.Params.Offset)
1818

‎api/v1/server/oas/transformers/v2/tasks.go‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ import (
99
"github.com/hatchet-dev/hatchet/api/v1/server/oas/gen"
1010
"github.com/hatchet-dev/hatchet/pkg/repository/olap"
1111
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
12-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
12+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
1313
"github.com/oapi-codegen/runtime/types"
1414
)
1515

@@ -19,7 +19,7 @@ func jsonToMap(jsonBytes []byte) map[string]interface{} {
1919
return result
2020
}
2121

22-
func ToTaskSummary(task *timescalev2.PopulateTaskRunDataRow) gen.V2TaskSummary {
22+
func ToTaskSummary(task *olapv2.PopulateTaskRunDataRow) gen.V2TaskSummary {
2323
additionalMetadata := jsonToMap(task.AdditionalMetadata)
2424

2525
var finishedAt *time.Time
@@ -62,7 +62,7 @@ func ToTaskSummary(task *timescalev2.PopulateTaskRunDataRow) gen.V2TaskSummary {
6262
}
6363

6464
func ToTaskSummaryRows(
65-
tasks []*timescalev2.PopulateTaskRunDataRow,
65+
tasks []*olapv2.PopulateTaskRunDataRow,
6666
) []gen.V2TaskSummary {
6767
toReturn := make([]gen.V2TaskSummary, len(tasks))
6868

@@ -74,7 +74,7 @@ func ToTaskSummaryRows(
7474
}
7575

7676
func ToDagChildren(
77-
tasks []*timescalev2.PopulateTaskRunDataRow,
77+
tasks []*olapv2.PopulateTaskRunDataRow,
7878
taskIdToDagExternalId map[int64]uuid.UUID,
7979
) []gen.V2DagChildren {
8080
dagIdToTasks := make(map[uuid.UUID][]gen.V2TaskSummary)
@@ -97,7 +97,7 @@ func ToDagChildren(
9797
}
9898

9999
func ToTaskSummaryMany(
100-
tasks []*timescalev2.PopulateTaskRunDataRow,
100+
tasks []*olapv2.PopulateTaskRunDataRow,
101101
total int, limit, offset int64,
102102
) gen.V2TaskSummaryList {
103103
toReturn := ToTaskSummaryRows(tasks)
@@ -117,7 +117,7 @@ func ToTaskSummaryMany(
117117
}
118118

119119
func ToTaskRunEventMany(
120-
events []*timescalev2.ListTaskEventsRow,
120+
events []*olapv2.ListTaskEventsRow,
121121
taskExternalId string,
122122
) gen.V2TaskEventList {
123123
toReturn := make([]gen.V2TaskEvent, len(events))
@@ -182,7 +182,7 @@ func ToTaskRunMetrics(metrics *[]olap.TaskRunMetric) gen.V2TaskRunMetrics {
182182
return toReturn
183183
}
184184

185-
func ToTask(taskWithData *timescalev2.PopulateSingleTaskRunDataRow) gen.V2Task {
185+
func ToTask(taskWithData *olapv2.PopulateSingleTaskRunDataRow) gen.V2Task {
186186
additionalMetadata := jsonToMap(taskWithData.AdditionalMetadata)
187187

188188
var finishedAt *time.Time

‎internal/services/controllers/v2/olap/controller.go‎

Lines changed: 48 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ import (
2222
"github.com/hatchet-dev/hatchet/pkg/repository"
2323
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
2424
v2 "github.com/hatchet-dev/hatchet/pkg/repository/v2"
25+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
2526
"github.com/hatchet-dev/hatchet/pkg/repository/v2/sqlcv2"
26-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
2727
)
2828

2929
type OLAPController interface {
@@ -300,8 +300,8 @@ func (tc *OLAPControllerImpl) handleCreateMonitoringEvent(ctx context.Context, t
300300
retryCounts := make([]int32, 0)
301301
workerIds := make([]string, 0)
302302
workflowIds := make([]pgtype.UUID, 0)
303-
eventTypes := make([]timescalev2.V2EventTypeOlap, 0)
304-
readableStatuses := make([]timescalev2.V2ReadableStatusOlap, 0)
303+
eventTypes := make([]olapv2.V2EventTypeOlap, 0)
304+
readableStatuses := make([]olapv2.V2ReadableStatusOlap, 0)
305305
eventPayloads := make([]string, 0)
306306
eventMessages := make([]string, 0)
307307
timestamps := make([]pgtype.Timestamptz, 0)
@@ -330,50 +330,50 @@ func (tc *OLAPControllerImpl) handleCreateMonitoringEvent(ctx context.Context, t
330330
}
331331

332332
switch msg.EventType {
333-
case timescalev2.V2EventTypeOlapRETRYING:
334-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
335-
case timescalev2.V2EventTypeOlapREASSIGNED:
336-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
337-
case timescalev2.V2EventTypeOlapRETRIEDBYUSER:
338-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
339-
case timescalev2.V2EventTypeOlapCREATED:
340-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
341-
case timescalev2.V2EventTypeOlapQUEUED:
342-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
343-
case timescalev2.V2EventTypeOlapREQUEUEDNOWORKER:
344-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
345-
case timescalev2.V2EventTypeOlapREQUEUEDRATELIMIT:
346-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapQUEUED)
347-
case timescalev2.V2EventTypeOlapASSIGNED:
348-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapRUNNING)
349-
case timescalev2.V2EventTypeOlapACKNOWLEDGED:
350-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapRUNNING)
351-
case timescalev2.V2EventTypeOlapSENTTOWORKER:
352-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapRUNNING)
353-
case timescalev2.V2EventTypeOlapSLOTRELEASED:
354-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapRUNNING)
355-
case timescalev2.V2EventTypeOlapSTARTED:
356-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapRUNNING)
357-
case timescalev2.V2EventTypeOlapTIMEOUTREFRESHED:
358-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapRUNNING)
359-
case timescalev2.V2EventTypeOlapSCHEDULINGTIMEDOUT:
360-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapFAILED)
361-
case timescalev2.V2EventTypeOlapFINISHED:
362-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapCOMPLETED)
363-
case timescalev2.V2EventTypeOlapFAILED:
364-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapFAILED)
365-
case timescalev2.V2EventTypeOlapCANCELLED:
366-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapCANCELLED)
367-
case timescalev2.V2EventTypeOlapTIMEDOUT:
368-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapFAILED)
369-
case timescalev2.V2EventTypeOlapRATELIMITERROR:
370-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapFAILED)
371-
case timescalev2.V2EventTypeOlapSKIPPED:
372-
readableStatuses = append(readableStatuses, timescalev2.V2ReadableStatusOlapCOMPLETED)
333+
case olapv2.V2EventTypeOlapRETRYING:
334+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
335+
case olapv2.V2EventTypeOlapREASSIGNED:
336+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
337+
case olapv2.V2EventTypeOlapRETRIEDBYUSER:
338+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
339+
case olapv2.V2EventTypeOlapCREATED:
340+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
341+
case olapv2.V2EventTypeOlapQUEUED:
342+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
343+
case olapv2.V2EventTypeOlapREQUEUEDNOWORKER:
344+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
345+
case olapv2.V2EventTypeOlapREQUEUEDRATELIMIT:
346+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapQUEUED)
347+
case olapv2.V2EventTypeOlapASSIGNED:
348+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapRUNNING)
349+
case olapv2.V2EventTypeOlapACKNOWLEDGED:
350+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapRUNNING)
351+
case olapv2.V2EventTypeOlapSENTTOWORKER:
352+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapRUNNING)
353+
case olapv2.V2EventTypeOlapSLOTRELEASED:
354+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapRUNNING)
355+
case olapv2.V2EventTypeOlapSTARTED:
356+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapRUNNING)
357+
case olapv2.V2EventTypeOlapTIMEOUTREFRESHED:
358+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapRUNNING)
359+
case olapv2.V2EventTypeOlapSCHEDULINGTIMEDOUT:
360+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapFAILED)
361+
case olapv2.V2EventTypeOlapFINISHED:
362+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapCOMPLETED)
363+
case olapv2.V2EventTypeOlapFAILED:
364+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapFAILED)
365+
case olapv2.V2EventTypeOlapCANCELLED:
366+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapCANCELLED)
367+
case olapv2.V2EventTypeOlapTIMEDOUT:
368+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapFAILED)
369+
case olapv2.V2EventTypeOlapRATELIMITERROR:
370+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapFAILED)
371+
case olapv2.V2EventTypeOlapSKIPPED:
372+
readableStatuses = append(readableStatuses, olapv2.V2ReadableStatusOlapCOMPLETED)
373373
}
374374
}
375375

376-
opts := make([]timescalev2.CreateTaskEventsOLAPParams, 0)
376+
opts := make([]olapv2.CreateTaskEventsOLAPParams, 0)
377377

378378
for i, taskId := range taskIds {
379379
var workerId pgtype.UUID
@@ -382,7 +382,7 @@ func (tc *OLAPControllerImpl) handleCreateMonitoringEvent(ctx context.Context, t
382382
workerId = sqlchelpers.UUIDFromStr(workerIds[i])
383383
}
384384

385-
event := timescalev2.CreateTaskEventsOLAPParams{
385+
event := olapv2.CreateTaskEventsOLAPParams{
386386
TenantID: sqlchelpers.UUIDFromStr(tenantId),
387387
TaskID: taskId,
388388
TaskInsertedAt: taskInsertedAts[i],
@@ -395,11 +395,11 @@ func (tc *OLAPControllerImpl) handleCreateMonitoringEvent(ctx context.Context, t
395395
}
396396

397397
switch eventTypes[i] {
398-
case timescalev2.V2EventTypeOlapFINISHED:
398+
case olapv2.V2EventTypeOlapFINISHED:
399399
event.Output = []byte(eventPayloads[i])
400-
case timescalev2.V2EventTypeOlapFAILED:
400+
case olapv2.V2EventTypeOlapFAILED:
401401
event.ErrorMessage = sqlchelpers.TextFromStr(eventPayloads[i])
402-
case timescalev2.V2EventTypeOlapCANCELLED:
402+
case olapv2.V2EventTypeOlapCANCELLED:
403403
event.AdditionalEventMessage = sqlchelpers.TextFromStr(eventMessages[i])
404404
}
405405

‎internal/services/controllers/v2/task/controller.go‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ import (
2727
"github.com/hatchet-dev/hatchet/pkg/repository"
2828
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
2929
v2 "github.com/hatchet-dev/hatchet/pkg/repository/v2"
30+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
3031
"github.com/hatchet-dev/hatchet/pkg/repository/v2/sqlcv2"
31-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
3232
)
3333

3434
type TasksController interface {
@@ -420,7 +420,7 @@ func (tc *TasksControllerImpl) handleTaskFailed(ctx context.Context, tenantId st
420420
tasktypes.CreateMonitoringEventPayload{
421421
TaskId: taskId,
422422
RetryCount: task.RetryCount,
423-
EventType: timescalev2.V2EventTypeOlapQUEUED,
423+
EventType: olapv2.V2EventTypeOlapQUEUED,
424424
EventTimestamp: time.Now(),
425425
},
426426
)
@@ -724,7 +724,7 @@ func (tc *TasksControllerImpl) signalTasksCreated(ctx context.Context, tenantId
724724
tasktypes.CreateMonitoringEventPayload{
725725
TaskId: task.ID,
726726
RetryCount: 0,
727-
EventType: timescalev2.V2EventTypeOlapQUEUED,
727+
EventType: olapv2.V2EventTypeOlapQUEUED,
728728
EventTimestamp: time.Now(),
729729
},
730730
)
@@ -829,7 +829,7 @@ func (tc *TasksControllerImpl) signalTasksCreatedAndCancelled(ctx context.Contex
829829
msg, err = tasktypes.MonitoringEventMessageFromInternal(tenantId, tasktypes.CreateMonitoringEventPayload{
830830
TaskId: taskCp.ID,
831831
RetryCount: taskCp.RetryCount,
832-
EventType: timescalev2.V2EventTypeOlapCANCELLED,
832+
EventType: olapv2.V2EventTypeOlapCANCELLED,
833833
EventTimestamp: time.Now(),
834834
})
835835

@@ -915,7 +915,7 @@ func (tc *TasksControllerImpl) signalTasksCreatedAndSkipped(ctx context.Context,
915915
msg, err = tasktypes.MonitoringEventMessageFromInternal(tenantId, tasktypes.CreateMonitoringEventPayload{
916916
TaskId: taskCp.ID,
917917
RetryCount: taskCp.RetryCount,
918-
EventType: timescalev2.V2EventTypeOlapSKIPPED,
918+
EventType: olapv2.V2EventTypeOlapSKIPPED,
919919
EventTimestamp: time.Now(),
920920
})
921921

‎internal/services/controllers/v2/task/process_reassignments.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"github.com/hatchet-dev/hatchet/internal/services/shared/tasktypes"
1111
"github.com/hatchet-dev/hatchet/internal/telemetry"
1212
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
13-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
13+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
1414
)
1515

1616
func (tc *TasksControllerImpl) runTenantReassignTasks(ctx context.Context) func() {
@@ -62,9 +62,9 @@ func (tc *TasksControllerImpl) processTaskReassignments(ctx context.Context, ten
6262

6363
switch task.Operation {
6464
case "REASSIGNED":
65-
monitoringEvent.EventType = timescalev2.V2EventTypeOlapREASSIGNED
65+
monitoringEvent.EventType = olapv2.V2EventTypeOlapREASSIGNED
6666
case "FAILED":
67-
monitoringEvent.EventType = timescalev2.V2EventTypeOlapFAILED
67+
monitoringEvent.EventType = olapv2.V2EventTypeOlapFAILED
6868
monitoringEvent.EventPayload = "Worker became inactive, and we reached the maximum number of internal retries"
6969
default:
7070
tc.l.Error().Msgf("unknown operation %s", task.Operation)

‎internal/services/controllers/v2/task/process_timeouts.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"github.com/hatchet-dev/hatchet/internal/services/shared/tasktypes"
1111
"github.com/hatchet-dev/hatchet/internal/telemetry"
1212
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
13-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
13+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
1414
)
1515

1616
func (tc *TasksControllerImpl) runTenantTimeoutTasks(ctx context.Context) func() {
@@ -57,7 +57,7 @@ func (tc *TasksControllerImpl) processTaskTimeouts(ctx context.Context, tenantId
5757
tasktypes.CreateMonitoringEventPayload{
5858
TaskId: taskId,
5959
RetryCount: task.RetryCount,
60-
EventType: timescalev2.V2EventTypeOlapTIMEDOUT,
60+
EventType: olapv2.V2EventTypeOlapTIMEDOUT,
6161
EventTimestamp: time.Now(),
6262
},
6363
)

‎internal/services/scheduler/scheduler.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import (
2222
"github.com/hatchet-dev/hatchet/pkg/repository"
2323
"github.com/hatchet-dev/hatchet/pkg/repository/prisma/sqlchelpers"
2424
repov2 "github.com/hatchet-dev/hatchet/pkg/repository/v2"
25-
"github.com/hatchet-dev/hatchet/pkg/repository/v2/timescalev2"
25+
"github.com/hatchet-dev/hatchet/pkg/repository/v2/olapv2"
2626
v2 "github.com/hatchet-dev/hatchet/pkg/scheduling/v2"
2727
)
2828

@@ -396,7 +396,7 @@ func (s *Scheduler) scheduleStepRuns(ctx context.Context, tenantId string, res *
396396
TaskId: taskId,
397397
RetryCount: bulkAssigned.QueueItem.RetryCount,
398398
WorkerId: &workerId,
399-
EventType: timescalev2.V2EventTypeOlapASSIGNED,
399+
EventType: olapv2.V2EventTypeOlapASSIGNED,
400400
EventTimestamp: time.Now(),
401401
},
402402
)
@@ -448,7 +448,7 @@ func (s *Scheduler) scheduleStepRuns(ctx context.Context, tenantId string, res *
448448
tenantId,
449449
schedulingTimedOut.TaskID,
450450
schedulingTimedOut.RetryCount,
451-
timescalev2.V2EventTypeOlapSCHEDULINGTIMEDOUT,
451+
olapv2.V2EventTypeOlapSCHEDULINGTIMEDOUT,
452452
)
453453

454454
if err != nil {
@@ -477,7 +477,7 @@ func (s *Scheduler) scheduleStepRuns(ctx context.Context, tenantId string, res *
477477
tasktypes.CreateMonitoringEventPayload{
478478
TaskId: taskId,
479479
RetryCount: unassigned.RetryCount,
480-
EventType: timescalev2.V2EventTypeOlapREQUEUEDNOWORKER,
480+
EventType: olapv2.V2EventTypeOlapREQUEUEDNOWORKER,
481481
EventTimestamp: time.Now(),
482482
},
483483
)

0 commit comments

Comments
 (0)