Method Err

pkg/repository/sqlcv1/copyfrom.go:110–112

()

}

func (r iteratorForCreateDAGData) Err() error {
	return nil
}

func (q *Queries) CreateDAGData(ctx context.Context, db DBTX, arg []CreateDAGDataParams) (int64, error) {
	return db.CopyFrom(ctx, []string{"v1_dag_data"}, []string{"dag_id", "dag_inserted_at", "input", "additional_metadata"}, &iteratorForCreateDAGData{rows: arg})