mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2025-12-30 13:19:44 -06:00
Code Issues Packages Projects Releases Wiki Activity

make sure to default to QUEUED for new task initial state (#1931)

Browse Source
This commit is contained in:
Mohammed Nafees
2025-07-02 14:45:09 +02:00
committed by GitHub
parent f06b8487eb
commit 144b8dce9e
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/repository/v1/match.go
View File

@@ -501,6 +501,7 @@ func (m *sharedRepository) processEventMatches(ctx context.Context, tx sqlcv1.DB
StepId: sqlchelpers.UUIDToStr(match.TriggerStepID),
StepIndex: int(match.TriggerStepIndex.Int64),
AdditionalMetadata: additionalMetadata,
InitialState: sqlcv1.V1TaskInitialStateQUEUED,
}
switch matchData.Action() {

6
pkg/repository/v1/task.go
View File

@@ -1586,6 +1586,9 @@ func (r *sharedRepository) insertTasks(
}
initialStates[i] = string(task.InitialState)
if initialStates[i] == "" {
initialStates[i] = string(sqlcv1.V1TaskInitialStateQUEUED)
}
if len(task.AdditionalMetadata) > 0 {
additionalMetadatas[i] = task.AdditionalMetadata
@@ -1996,6 +1999,9 @@ func (r *sharedRepository) replayTasks(
inputs[i] = r.ToV1StepRunData(task.Input).Bytes()
}
initialStates[i] = string(task.InitialState)
if initialStates[i] == "" {
initialStates[i] = string(sqlcv1.V1TaskInitialStateQUEUED)
}
if len(task.AdditionalMetadata) > 0 {
additionalMetadatas[i] = task.AdditionalMetadata