MCPcopy Create free account
hub / github.com/encoder-run/operator / _PipelineExecution

Method _PipelineExecution

pkg/graph/generated.go:7579–7619  ·  view source on GitHub ↗
(ctx context.Context, sel ast.SelectionSet, obj *model.PipelineExecution)

Source from the content-addressed store, hash-verified

7577var pipelineExecutionImplementors = []string{"PipelineExecution"}
7578
7579func (ec *executionContext) _PipelineExecution(ctx context.Context, sel ast.SelectionSet, obj *model.PipelineExecution) graphql.Marshaler {
7580 fields := graphql.CollectFields(ec.OperationContext, sel, pipelineExecutionImplementors)
7581
7582 out := graphql.NewFieldSet(fields)
7583 deferred := make(map[string]*graphql.FieldSet)
7584 for i, field := range fields {
7585 switch field.Name {
7586 case "__typename":
7587 out.Values[i] = graphql.MarshalString("PipelineExecution")
7588 case "id":
7589 out.Values[i] = ec._PipelineExecution_id(ctx, field, obj)
7590 if out.Values[i] == graphql.Null {
7591 out.Invalids++
7592 }
7593 case "status":
7594 out.Values[i] = ec._PipelineExecution_status(ctx, field, obj)
7595 if out.Values[i] == graphql.Null {
7596 out.Invalids++
7597 }
7598 default:
7599 panic("unknown field " + strconv.Quote(field.Name))
7600 }
7601 }
7602 out.Dispatch(ctx)
7603 if out.Invalids > 0 {
7604 return graphql.Null
7605 }
7606
7607 atomic.AddInt32(&ec.deferred, int32(len(deferred)))
7608
7609 for label, dfs := range deferred {
7610 ec.processDeferredGroup(graphql.DeferredGroup{
7611 Label: label,
7612 Path: graphql.GetPath(ctx),
7613 FieldSet: dfs,
7614 Context: ctx,
7615 })
7616 }
7617
7618 return out
7619}
7620
7621var queryImplementors = []string{"Query"}
7622

Calls 3

_PipelineExecution_idMethod · 0.95
processDeferredGroupMethod · 0.95

Tested by

no test coverage detected