def generate_mv_params()

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

• 15 lines of code
• 1 McCabe index (conditional complexity)

def generate_mv_params(**context):
    files_to_process = context["ti"].xcom_pull(
        key="return_value",
        task_ids="initial_load_from_input_bucket.move_duplicated_files_to_rejected_bucket",
    )
    process_folder = context["ti"].xcom_pull(
        task_ids="initial_load_from_input_bucket.create_process_folder",
        key="process_folder",
    )
    input_folder = context["params"]["input_folder"]
    process_bucket = os.environ.get("DPU_PROCESS_BUCKET")

    parameter_obj_list = file_utils.get_mv_params(
        files_to_process, input_folder, process_bucket, process_folder
    )
    return parameter_obj_list