Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

And the also fairly simple task:
`@task(target='{task_name}/{scan_id}', checkpoint=True, nout=2)`
def bourget2bids(participant_id: str, scan_id: str, study_constants):
    tmp_BIDS_dir, bourget_path = get_from_bourget(participant_id, scan_id, study_constants['name'], study_constants['scripts_dir'])
    add_ASL_metadata(scan_id, study_constants['name'])
    BIDS_path = copy_to_study_data_folder(participant_id, scan_id, tmp_BIDS_dir, study_constants['name'], study_constants['data_dir'])
    return bourget_path, BIDS_path