diff --git a/lib/query-emitter.js b/lib/query-emitter.js index 9e1994eef..79877bc31 100644 --- a/lib/query-emitter.js +++ b/lib/query-emitter.js @@ -202,7 +202,7 @@ QueryEmitter.prototype.queryPoll = function(callback) { var inserted = getInserted(idsDiff); if (inserted.length) { var snapshotOptions = {}; - if (emitter.agent) snapshotOptions.agentCustom = emitter.agent.custom; + snapshotOptions.agentCustom = emitter.agent.custom; function _getSnapshotBulkCb(err, snapshotMap) { if (err) return emitter._finishPoll(err, callback, pending);