-record(pipeline, {
    collection :: mongo@client:collection(),
    options :: list(mongo@aggregation:aggregate_option()),
    stages :: gleam@queue:queue(bson@value:value())
}).