def create_map_job(config, internal_storage, executor_id, job_id, map_function, iterdata, runtime_meta, runtime_memory, extra_env, include_modules, exclude_modules, execution_timeout, extra_args=None, obj_chunk_size=None, obj_chunk_number=None, invoke_pool_threads=128):
    '\n    Wrapper to create a map job.  It integrates COS logic to process objects.\n    '
    host_job_meta = {'host_job_create_tstamp': time.time()}
    map_iterdata = utils.verify_args(map_function, iterdata, extra_args)
    if config['lithops'].get('rabbitmq_monitor', False):
        rabbit_amqp_url = config['rabbitmq'].get('amqp_url')
        utils.create_rabbitmq_resources(rabbit_amqp_url, executor_id, job_id)
    parts_per_object = None
    if is_object_processing_function(map_function):
        create_partitions_start = time.time()
        logger.debug('ExecutorID {} | JobID {} - Calling map on partitions from object storage flow'.format(executor_id, job_id))
        (map_iterdata, parts_per_object) = create_partitions(config, internal_storage, map_iterdata, obj_chunk_size, obj_chunk_number)
        host_job_meta['host_job_create_partitions_time'] = round((time.time() - create_partitions_start), 6)
    job = _create_job(config=config, internal_storage=internal_storage, executor_id=executor_id, job_id=job_id, func=map_function, iterdata=map_iterdata, runtime_meta=runtime_meta, runtime_memory=runtime_memory, extra_env=extra_env, include_modules=include_modules, exclude_modules=exclude_modules, execution_timeout=execution_timeout, host_job_meta=host_job_meta, invoke_pool_threads=invoke_pool_threads)
    if parts_per_object:
        job.parts_per_object = parts_per_object
    return job
Wrapper to create a map job.  It integrates COS logic to process objects.
def create_map_job(config, internal_storage, executor_id, job_id, map_function, iterdata, runtime_meta, runtime_memory, extra_env, include_modules, exclude_modules, execution_timeout, extra_args=None, obj_chunk_size=None, obj_chunk_number=None, invoke_pool_threads=128):
    '\n    \n    '
    host_job_meta = {'host_job_create_tstamp': time.time()}
    map_iterdata = utils.verify_args(map_function, iterdata, extra_args)
    if config['lithops'].get('rabbitmq_monitor', False):
        rabbit_amqp_url = config['rabbitmq'].get('amqp_url')
        utils.create_rabbitmq_resources(rabbit_amqp_url, executor_id, job_id)
    parts_per_object = None
    if is_object_processing_function(map_function):
        create_partitions_start = time.time()
        logger.debug('ExecutorID {} | JobID {} - Calling map on partitions from object storage flow'.format(executor_id, job_id))
        (map_iterdata, parts_per_object) = create_partitions(config, internal_storage, map_iterdata, obj_chunk_size, obj_chunk_number)
        host_job_meta['host_job_create_partitions_time'] = round((time.time() - create_partitions_start), 6)
    job = _create_job(config=config, internal_storage=internal_storage, executor_id=executor_id, job_id=job_id, func=map_function, iterdata=map_iterdata, runtime_meta=runtime_meta, runtime_memory=runtime_memory, extra_env=extra_env, include_modules=include_modules, exclude_modules=exclude_modules, execution_timeout=execution_timeout, host_job_meta=host_job_meta, invoke_pool_threads=invoke_pool_threads)
    if parts_per_object:
        job.parts_per_object = parts_per_object
    return job