function initializeActivityQueue() {
  if (!process.env.INITIALIZE_ACTIVITY_QUEUE) {
    console.log('Requires env var to intialize activity ingest queue');
    return;
  }

  console.log('Initializing activity ingest queue');
  const interval = setInterval(() => {
    if (!process.env.INITIALIZE_ACTIVITY_QUEUE) {
      console.log('Canceling scheduled activity queue ingestion');
      clearInterval(interval);
    }
    processQueue(
      { status: 'pending' },
      { isDryRun: PROCESS_QUEUE_AS_DRY_RUN },
    );
  }, INGEST_QUEUE_INTERVAL);
}
/**
 * Fire up the standard ingestion queue for pending activities
 */
Fire up the standard ingestion queue for pending activities
Fire up the standard ingestion queue for pending activities
function initializeActivityQueue() {
  if (!process.env.INITIALIZE_ACTIVITY_QUEUE) {
    console.log('Requires env var to intialize activity ingest queue');
    return;
  }
  console.log('Initializing activity ingest queue');
  const interval = setInterval(() => {
    if (!process.env.INITIALIZE_ACTIVITY_QUEUE) {
      console.log('Canceling scheduled activity queue ingestion');
      clearInterval(interval);
    }
    processQueue(
      { status: 'pending' },
      { isDryRun: PROCESS_QUEUE_AS_DRY_RUN },
    );
  }, INGEST_QUEUE_INTERVAL);
}
function initializeActivityQueue ( ) { if ( ! process . env . INITIALIZE_ACTIVITY_QUEUE ) { console . log ( 'Requires env var to intialize activity ingest queue' ) ; return ; } console . log ( 'Initializing activity ingest queue' ) ; const interval = setInterval ( ( ) => { if ( ! process . env . INITIALIZE_ACTIVITY_QUEUE ) { console . log ( 'Canceling scheduled activity queue ingestion' ) ; clearInterval ( interval ) ; } processQueue ( { status : 'pending' } , { isDryRun : PROCESS_QUEUE_AS_DRY_RUN } , ) ; } , INGEST_QUEUE_INTERVAL ) ; }
Fire up the standard ingestion queue for pending activities
Fire up the standard ingestion queue for pending activities