-record(pipeline, {
    collection :: mongo@client:collection(),
    stages :: gleam@queue:queue(bson@types:value())
}).