def get_mv_params()

in components/dpu-workflow/src/utils/file_utils.py [0:0]

• 11 lines of code
• 3 McCabe index (conditional complexity)

def get_mv_params(files_to_process, input_folder, process_bucket, process_folder):
    input_folder_with_prefix = f"{input_folder}/" if input_folder else ""
    parameter_obj_list = []
    for typ in files_to_process.keys():
        parameter_obj = {
            "source_object": f"{input_folder_with_prefix}*.{typ}",
            "destination_bucket": process_bucket,
            "destination_object": f"{process_folder}/{typ}/",
        }
        parameter_obj_list.append(parameter_obj)
    return parameter_obj_list