func (s *BoltStore) CreatePipelinePut(p *gaia.CreatePipeline) error {
	return s.db.Update(func(tx *bolt.Tx) error {
		b := tx.Bucket(createPipelineBucket)
		m, err := json.Marshal(p)
		if err != nil {
			return err
		}
		return b.Put([]byte(p.ID), m)
	})
}
CreatePipelinePut adds a pipeline which
is not yet compiled but is about to.
package store
import (
	"encoding/json"
	bolt "go.etcd.io/bbolt"
	"github.com/gaia-pipeline/gaia"
)