def METHOD_NAME() -> PipelineJob:
    cosmos_folder = Input(
        path=parent_dir + "/data/iris_model",
        type=AssetTypes.URI_FOLDER,
    )
    cosmos_folder_dup = Input(
        path=parent_dir + "/data/iris_model",
        type=AssetTypes.URI_FOLDER,
    )
    inputs = {
        "folder1": cosmos_folder,
        "folder2": cosmos_folder_dup,
    }
    outputs = {"output_folder": Output(type=AssetTypes.URI_FOLDER)}
    merge_files_func = copy_data(
        inputs=inputs,
        outputs=outputs,
        data_copy_mode=DataCopyMode.MERGE_WITH_OVERWRITE,
    )
    # Define pipeline
    @dsl.pipeline(description="submit a pipeline with data transfer copy job")
    def data_transfer_copy_pipeline_from_builder(cosmos_folder, cosmos_folder_dup):
        merge_files = merge_files_func(folder1=cosmos_folder, folder2=cosmos_folder_dup)
        return {"merged_blob": merge_files.outputs.output_folder}
    pipeline = data_transfer_copy_pipeline_from_builder(
        cosmos_folder=cosmos_folder, cosmos_folder_dup=cosmos_folder_dup
    )
    pipeline.settings.default_compute = SERVERLESS_COMPUTE
    return pipeline