from __future__ import absolute_import
from __future__ import unicode_literals

import time

from django.core.management.base import BaseCommand
from corehq.apps.userreports.tasks import _get_config_by_id, _build_indicators
from corehq.apps.change_feed.data_sources import get_document_store_for_doc_type
from custom.icds_reports.models.aggregate import CcsRecordMonthly
from pillowtop.dao.couch import ID_CHUNK_SIZE


class Command(BaseCommand):
    help = "Rebuild ccs record cases ucr for pnc_complete"

    def handle(self):
        indicator_config_id = 'static-ccs_record_cases'
        case_type_of_xmlns = 'ccs_record'
        config = _get_config_by_id(indicator_config_id)
        document_store = get_document_store_for_doc_type(
            config.domain, config.referenced_doc_type, case_type_or_xmlns=case_type_of_xmlns
        )

        doc_ids = CcsRecordMonthly.objects.filter(pnc_complete=1).values('case_id')
        relevant_ids = list()
        next_event = time.time() + 10
        for doc_id in doc_ids:
            relevant_ids.append(doc_id['case_id'])
            if len(relevant_ids) >= ID_CHUNK_SIZE:
                _build_indicators(config, document_store, relevant_ids)
                relevant_ids = []

            if time.time() > next_event:
                print("processed till case %s" % (doc_id['case_id']))
                next_event = time.time() + 10

        if relevant_ids:
            _build_indicators(config, document_store, relevant_ids)


from __future__ import absolute_import, print_function
from __future__ import unicode_literals

import time

from django.core.management.base import BaseCommand
from corehq.apps.userreports.tasks import _get_config_by_id, _build_indicators
from corehq.apps.change_feed.data_sources import get_document_store_for_doc_type
from custom.icds_reports.models.aggregate import CcsRecordMonthly
from pillowtop.dao.couch import ID_CHUNK_SIZE


class Command(BaseCommand):
    help = "Rebuild ccs record cases ucr for pnc_complete"

    def handle(self):
        indicator_config_id = 'static-ccs_record_cases'
        case_type_of_xmlns = 'ccs_record'
        config = _get_config_by_id(indicator_config_id)
        document_store = get_document_store_for_doc_type(
            config.domain, config.referenced_doc_type, case_type_or_xmlns=case_type_of_xmlns
        )

        doc_ids = CcsRecordMonthly.objects.filter(pnc_complete=1).values('case_id')
        relevant_ids = list()
        next_event = time.time() + 10
        for doc_id in doc_ids:
            relevant_ids.append(doc_id['case_id'])
            if len(relevant_ids) >= ID_CHUNK_SIZE:
                _build_indicators(config, document_store, relevant_ids)
                relevant_ids = []

            if time.time() > next_event:
                print("processed till case %s" % (doc_id['case_id']))
                next_event = time.time() + 10

        if relevant_ids:
            _build_indicators(config, document_store, relevant_ids)

Add print_funtion from __future__