-record(database_source, {
    name :: binary(),
    'query' :: binary(),
    batch_size :: integer()
}).