if (options.source) {
    query['source.id'] = options.source.id;
    query['source.objectType'] = options.source.objectType;
  }