(async_indicators, use_agg_queue=False)
Extract doc ids for the passed AsyncIndicators and queue task to process indicators for them.
        Mark date_queued on all AsyncIndicator passed to utcnow.
Extract doc ids for the passed AsyncIndicators and queue task to process indicators for them.
        Mark date_queued on all AsyncIndicator passed to utcnow.
Extract doc ids for the passed AsyncIndicators and queue task to process indicators for them . Mark date_queued on all AsyncIndicator passed to utcnow .
def _queue_indicators(async_indicators, use_agg_queue=False):
    """
        Extract doc ids for the passed AsyncIndicators and queue task to process indicators for them.
        Mark date_queued on all AsyncIndicator passed to utcnow.
    """
    for chunk in chunked(async_indicators, ASYNC_INDICATOR_CHUNK_SIZE):
        now = datetime.utcnow()
        indicator_doc_ids = [i.doc_id for i in chunk]
        # AsyncIndicator have doc_id as a unique column, so this update would only
        # update the passed AsyncIndicators
        AsyncIndicator.objects.filter(doc_id__in=indicator_doc_ids).update(date_queued=now)
        if use_agg_queue:
            build_indicators_with_agg_queue.delay(indicator_doc_ids)
        else:
            build_async_indicators.delay(indicator_doc_ids)
def _queue_indicators ( async_indicators , use_agg_queue = False ) : for chunk in chunked ( async_indicators , ASYNC_INDICATOR_CHUNK_SIZE ) : now = datetime . utcnow ( ) indicator_doc_ids = [ i . doc_id for i in chunk ] # AsyncIndicator have doc_id as a unique column, so this update would only # update the passed AsyncIndicators AsyncIndicator . objects . filter ( doc_id__in = indicator_doc_ids ) . update ( date_queued = now ) if use_agg_queue : build_indicators_with_agg_queue . delay ( indicator_doc_ids ) else : build_async_indicators . delay ( indicator_doc_ids )