serj-p

#!/usr/bin/python2.7
import ssl

from time import time
from contextlib import closing

login = 'hidden'
pw = 'hidden'
server = "outlook.office365.com"
smtp_port=587

serj-p

 "query": {
      "sort": [],
      "from": 0,
      "_source": [],
      "query": {
        "filtered": {
          "filter": {
            "term": {
              "company_id": "4e7fabeab2890b35852c8785"
            }

serj-p

    See more at @url https://developers.google.com/+/api/latest/people

        :param gplus_id: A unique identifier for this user.
        :type gplus_id: unicode

        :param given_name: A user's first name.
        :type given_name: unicode

        :param family_name: A user's last name.
        :type family_name: unicode

serj-p

diff --git a/src/nimble_contacts/nimble_contacts/rest/controllers.py b/src/nimble_contacts/nimble_contacts/rest/controllers.py
index 375ace1..a6ce793 100644
--- a/src/nimble_contacts/nimble_contacts/rest/controllers.py
+++ b/src/nimble_contacts/nimble_contacts/rest/controllers.py
@@ -2,10 +2,7 @@ import re
 import math
 from logging import getLogger

-from dateutil.parser import parse
-from datetime import timedelta, datetime

serj-p

class SavedSearchQueryPreTranslator(INSESearchQueryPreTranslator):
    def __init__(self, contact_q):
        """
        :param contact_q:
        :type contact_q: nimble_contacts.new_search.domain.ContactsNSERequest
        """
        self.contact_q = contact_q

    def process_terminal(self, query):
        if query.field_name == "saved_search" and query.occurence == OccurrenceTypes.IS:

serj-p

{
  'or': [
     {TerminalQ1},
     {Terminalq2},
     {
        'and': [
           {TerminalQ3}, {TerminalQ4}
        ]
     }
  ]

serj-p

from celery.exceptions import Retry
from nimble_base.celery.api import celery
from nimble_core.search.bgtasks import ESTask
from nimble_core.search.models import AsyncESCluster, ESCluster

from ntests import *
from pyes.exceptions import NoServerAvailable


class RetryTest(object):

serj-p

from celery.exceptions import Retry
from nimble_base.celery.api import celery
from nimble_core.search.bgtasks import ESTask
from nimble_core.search.domain import ESDocument, ESDocumentContent
from nimble_core.search.models import AsyncESCluster, ESCluster

from ntests import *
from pyes.exceptions import NoServerAvailable
from wtforms.validators import UUID

serj-p

def F_DEFAULT_MULTIFIELD_MAPPING_IN_ALL(f_name):
    return {
        "fields": {
            f_name: ANALYZED_FIELD_MAPPING_IN_ALL,
            'na': NA_MAPPING
        },
        "type": "multi_field",
        "include_in_all": True
    }

serj-p

<14>1 2012-11-09T12:48:08.000000Z ip-10-253-0-26 contacts_rest_api 13469 MSGID13524652884394083 [default path="/mnt/nimble/src/nimble_search/nimble_search/es.py:149" role="app" service="contacts_rest_api" levelname="INFO" funcName="delay"] Task 'Index documents to ElasticSearch' ['dd9bfce7-4799-42e6-825e-2d5b02e9f216'] was sent to broker
<14>1 2012-11-09T15:04:42.000000Z ip-10-244-7-130 celeryd 22360 MSGID13524734822921806 [default path="/mnt/nimble/eggs/celery-3.0.9nimble-py2.7.egg/celery/worker/consumer.py:487" role="taskbroker" service="celeryd" levelname="INFO" funcName="on_task"] Got task from broker: Index documents to ElasticSearch[dd9bfce7-4799-42e6-825e-2d5b02e9f216]
<14>1 2012-11-09T15:05:00.000000Z ip-10-244-7-130 <string> 22375 MSGID1352473500363040 [default path="/mnt/nimble/src/nimble_search/nimble_search/es.py:136" role="taskbroker" service="<string>" levelname="INFO" funcName="retry"] Task 'Index documents to ElasticSearch' ['dd9bfce7-4799-42e6-825e-2d5b02e9f216'] was started
<14>1 2012-11-