( ctx context.Context, dag *dagql.Server, _ uint64, _ *dagql.ResultCall, payload json.RawMessage, )
| 271 | } |
| 272 | |
| 273 | func (*Generator) DecodePersistedObject( |
| 274 | ctx context.Context, |
| 275 | dag *dagql.Server, |
| 276 | _ uint64, |
| 277 | _ *dagql.ResultCall, |
| 278 | payload json.RawMessage, |
| 279 | ) (dagql.Typed, error) { |
| 280 | var persisted persistedGeneratorObjectPayload |
| 281 | if err := json.Unmarshal(payload, &persisted); err != nil { |
| 282 | return nil, fmt.Errorf("decode persisted generator payload: %w", err) |
| 283 | } |
| 284 | nodes, err := decodePersistedModTree(ctx, dag, persisted.Tree) |
| 285 | if err != nil { |
| 286 | return nil, err |
| 287 | } |
| 288 | return decodePersistedGeneratorPayload(ctx, dag, nodes, persisted.Generator) |
| 289 | } |
| 290 | |
| 291 | func (g *Generator) AttachDependencyResults( |
| 292 | ctx context.Context, |
nothing calls this directly
no test coverage detected