def METHOD_NAME(
    graph_id: str, dataset: click.Path, raw: bool, test: bool, retry: bool
):
    """
    Main ingest command.
    Takes ingest config from a yaml file and queues atomic tasks.
    """
    from .cluster import enqueue_atomic_tasks
    with open(dataset, "r") as stream:
        config = yaml.safe_load(stream)
    meta, ingest_config, client_info = bootstrap(
        graph_id,
        config=config,
        raw=raw,
        test_run=test,
    )
    cg = ChunkedGraph(meta=meta, client_info=client_info)
    if not retry:
        cg.create()
    enqueue_atomic_tasks(IngestionManager(ingest_config, meta))