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