import json
import logging
import argparse
import numpy as np
import uuid

import emission.pipeline.intake_stage as epi
import emission.core.wrapper.user as ecwu

if __name__ == '__main__':
    np.random.seed(61297777)

    parser = argparse.ArgumentParser(prog="intake_single_user")
    group = parser.add_mutually_exclusive_group(required=True)
    group.add_argument("-e", "--user_email")
    group.add_argument("-u", "--user_uuid")

    args = parser.parse_args()

    if args.user_uuid:
        sel_uuid = uuid.UUID(args.user_uuid)
    else:
        sel_uuid = ecwu.User.fromEmail(args.user_email).uuid

    epi.run_intake_pipeline("single", [sel_uuid])

Add a simple script that runs the pipeline for the single specified user