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

fix: payload fallback for child runs (#2421)

Browse Source
This commit is contained in:
matt
2025-10-15 16:16:51 -04:00
committed by GitHub
parent b16be655be
commit aa38c6d2df
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/repository/v1/trigger.go
View File

@@ -1521,13 +1521,18 @@ func (r *TriggerRepositoryImpl) registerChildWorkflows(
rootExternalIdsToLookup := make([]pgtype.UUID, 0, len(matchingEvents))
for _, event := range matchingEvents {
payload := payloads[RetrievePayloadOpts{
payload, ok := payloads[RetrievePayloadOpts{
Id: event.ID,
InsertedAt: event.InsertedAt,
Type: sqlcv1.V1PayloadTypeTASKEVENTDATA,
TenantId: sqlchelpers.UUIDFromStr(tenantId),
}]
if !ok {
r.l.Error().Msgf("registerChildWorkflows: event with inserted at %s and id %d has empty payload, falling back to input", event.InsertedAt.Time, event.ID)
payload = event.Data
}
c, err := newChildWorkflowSignalCreatedDataFromBytes(payload)
if err != nil {