def _search_batches()

in app/poller.py [0:0]

• 16 lines of code
• 6 McCabe index (conditional complexity)

def _search_batches():
    since_id = None
    if STREAM_MODE_ENABLED:
        since_id = checkpoint.last_id()

    tweets = []
    while True:
        result = twitter_proxy.search(SEARCH_TEXT, since_id)
        if not result['statuses']:
            # no more results
            break

        tweets = result['statuses']
        size = len(tweets)
        for i in range(0, size, BATCH_SIZE):
            yield tweets[i:min(i + BATCH_SIZE, size)]
        since_id = result['search_metadata']['max_id']

        if STREAM_MODE_ENABLED:
            checkpoint.update(since_id)