Eventing: No inter handler recursion error with collections

./testrunner -i vikas-nodes.ini -t eventing.eventing_source_mutation.EventingSourceMutation.test_inter_handler_recursion,nodes_init=4,services_init=kv-eventing-index-n1ql,dataset=default,groups=simple,reset_services=True,skip_cleanup=True,source_bucket_mutation=true 

2020-11-09 20:01:37 | INFO | MainProcess | test_thread | [eventing_base.deploy_function] Deploying the following handler code : Function_480073060_test_inter_handler_recursion with

bindings: {'buckets': [{'alias': 'src_bucket', 'bucket_name': 'src_bucket', 'access': 'rw'}], 'metadata_bucket': 'metadata', 'source_bucket': 'src_bucket', 'curl': []} and

settings: {'checkpoint_interval': 20000, 'cleanup_timers': False, 'dcp_stream_boundary': 'everything', 'deployment_status': False, 'description': 'Sample Description', 'log_level': 'INFO', 'skip_timer_threshold': 86400, 'sock_batch_size': 1, 'tick_duration': 5000, 'timer_processing_tick_interval': 500, 'timer_worker_pool_size': 3, 'worker_count': 3, 'processing_status': False, 'cpp_worker_thread_count': 1, 'execution_timeout': 20, 'data_chan_size': 10000, 'worker_queue_cap': 100000, 'use_memory_manager': True, 'deadline_timeout': 21, 'timer_storage_chan_size': 10000, 'dcp_gen_chan_size': 10000, 'language_compatibility': '6.5.0'}

2020-11-09 20:01:37 | INFO | MainProcess | test_thread | [eventing_base.deploy_function]

function OnUpdate(doc, meta) {

    log('document', doc);

    while(true){

    try {

        var time_rand = random_gen();

        src_bucket[meta.id + time_rand] = doc;

        break;

    } catch(e) {

        log(e);

    }

    }

}

function random_gen(){

    var rand = Math.floor(Math.random() * 20000000) * Math.floor(Math.random() * 20000000);

    var time_rand = Math.round((new Date()).getTime() / 1000) + rand;

    return time_rand;

} 

2020-11-09 20:02:05 | INFO | MainProcess | test_thread | [eventing_base.deploy_function] Deploying the following handler code : Function_480073060_test_inter_handler_recursion_2 with

bindings: {'buckets': [{'alias': 'src_bucket', 'bucket_name': 'src_bucket', 'access': 'rw'}], 'metadata_bucket': 'metadata', 'source_bucket': 'src_bucket', 'curl': []} and

settings: {'checkpoint_interval': 20000, 'cleanup_timers': False, 'dcp_stream_boundary': 'everything', 'deployment_status': False, 'description': 'Sample Description', 'log_level': 'INFO', 'skip_timer_threshold': 86400, 'sock_batch_size': 1, 'tick_duration': 5000, 'timer_processing_tick_interval': 500, 'timer_worker_pool_size': 3, 'worker_count': 3, 'processing_status': False, 'cpp_worker_thread_count': 1, 'execution_timeout': 20, 'data_chan_size': 10000, 'worker_queue_cap': 100000, 'use_memory_manager': True, 'deadline_timeout': 21, 'timer_storage_chan_size': 10000, 'dcp_gen_chan_size': 10000, 'language_compatibility': '6.5.0'}

2020-11-09 20:02:05 | INFO | MainProcess | test_thread | [eventing_base.deploy_function]

function OnUpdate(doc, meta) {

    log('document', doc);

    while(true){

    try {

        var time_rand = random_gen();

        src_bucket[meta.id + time_rand] = doc;

        break;

    } catch(e) {

        log(e);

    }

    }

}

function random_gen(){

    var rand = Math.floor(Math.random() * 20000000) * Math.floor(Math.random() * 20000000);

    var time_rand = Math.round((new Date()).getTime() / 1000) + rand;

    return time_rand;

}