mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-02-19 22:59:08 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix: use SplitN instead of Split (#2336)

Browse Source
This commit is contained in:
matt
2025-09-24 15:26:38 -04:00
committed by GitHub
parent 2e38807666
commit d2cab4924a
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
api/v1/server/handlers/events/list.go
View File

@@ -83,7 +83,7 @@ func (t *EventService) EventList(ctx echo.Context, request gen.EventListRequestO
additionalMetadata := make(map[string]interface{}, len(*request.Params.AdditionalMetadata))
for _, v := range *request.Params.AdditionalMetadata {
splitValue := strings.Split(fmt.Sprintf("%v", v), ":")
splitValue := strings.SplitN(fmt.Sprintf("%v", v), ":", 2)
if len(splitValue) == 2 {
additionalMetadata[splitValue[0]] = splitValue[1]
@@ -192,7 +192,7 @@ func (t *EventService) EventList(ctx echo.Context, request gen.EventListRequestO
additionalMeta := make(map[string]interface{})
for _, m := range *request.Params.AdditionalMetadata {
split := strings.Split(m, ":")
split := strings.SplitN(m, ":", 2)
if len(split) != 2 {
return nil, fmt.Errorf("invalid additional metadata format: %s, expected key:value", m)

2
api/v1/server/handlers/v1/events/list.go
View File

@@ -97,7 +97,7 @@ func (t *V1EventsService) V1EventList(ctx echo.Context, request gen.V1EventListR
additionalMeta := make(map[string]interface{})
for _, m := range *request.Params.AdditionalMetadata {
split := strings.Split(m, ":")
split := strings.SplitN(m, ":", 2)
if len(split) != 2 {
return nil, fmt.Errorf("invalid additional metadata format: %s, expected key:value", m)

2
api/v1/server/handlers/v1/tasks/get_metrics.go
View File

@@ -44,7 +44,7 @@ func (t *TasksService) V1TaskListStatusMetrics(ctx echo.Context, request gen.V1T
if request.Params.AdditionalMetadata != nil {
for _, v := range *request.Params.AdditionalMetadata {
kv_pairs := strings.Split(v, ":")
kv_pairs := strings.SplitN(v, ":", 2)
if len(kv_pairs) == 2 {
additionalMetadataFilters[kv_pairs[0]] = kv_pairs[1]
}

4
api/v1/server/handlers/v1/workflow-runs/list.go
View File

@@ -69,7 +69,7 @@ func (t *V1WorkflowRunsService) WithDags(ctx context.Context, request gen.V1Work
if request.Params.AdditionalMetadata != nil {
for _, v := range *request.Params.AdditionalMetadata {
kv_pairs := strings.Split(v, ":")
kv_pairs := strings.SplitN(v, ":", 2)
if len(kv_pairs) == 2 {
additionalMetadataFilters[kv_pairs[0]] = kv_pairs[1]
}
@@ -235,7 +235,7 @@ func (t *V1WorkflowRunsService) OnlyTasks(ctx context.Context, request gen.V1Wor
if request.Params.AdditionalMetadata != nil {
for _, v := range *request.Params.AdditionalMetadata {
kv_pairs := strings.Split(v, ":")
kv_pairs := strings.SplitN(v, ":", 2)
if len(kv_pairs) == 2 {
additionalMetadataFilters[kv_pairs[0]] = kv_pairs[1]
}

4
internal/services/admin/v1/server.go
View File

@@ -72,7 +72,7 @@ func (a *AdminServiceImpl) CancelTasks(ctx context.Context, req *contracts.Cance
if len(req.Filter.AdditionalMetadata) > 0 {
additionalMetadataFilters = make(map[string]interface{})
for _, v := range req.Filter.AdditionalMetadata {
kv_pairs := strings.Split(v, ":")
kv_pairs := strings.SplitN(v, ":", 2)
if len(kv_pairs) == 2 {
additionalMetadataFilters[kv_pairs[0]] = kv_pairs[1]
} else {
@@ -200,7 +200,7 @@ func (a *AdminServiceImpl) ReplayTasks(ctx context.Context, req *contracts.Repla
if len(req.Filter.AdditionalMetadata) > 0 {
additionalMetadataFilters = make(map[string]interface{})
for _, v := range req.Filter.AdditionalMetadata {
kv_pairs := strings.Split(v, ":")
kv_pairs := strings.SplitN(v, ":", 2)
if len(kv_pairs) == 2 {
additionalMetadataFilters[kv_pairs[0]] = kv_pairs[1]
} else {