import pipedream.api


def get_pipedef():
    pipedef = {
        "name": "Road_Segment_Metrics_All_Vehicle",
        "job": []
    }

    new_job = {
        "name": "Road_Segment_Metrics_For_NovDec_All_Vehicle",
        "command": "bazel run //experimental/vaibhav/intersection_disengagements_metrics:intersection_disengagements_metrics --",
        "arg": [
            "--start_timestamp=1509494400000000000",
            "--end_timestamp=1513730164000000000",
        ],
        "taskCount": 1,
        "slackAlertTarget": ["@vaibhav"],
        "alertEmail": ["vaibhav@zoox.com"],
        "branch": "INFRA-3459-road-segments-disengagements-analysis",
    }

    pipedef["job"].append(new_job)
    return pipedef

if __name__ == '__main__':
    print pipedream.api.schedule(get_pipedef())