Quickstart¶

To start off, distilabel is a framework for building pipelines for generating synthetic data using LLMs, that defines a Pipeline which orchestrates the execution of the Step subclasses, and those will be connected as nodes in a Direct Acyclic Graph (DAG).

That being said, in this guide we will walk you through the process of creating a simple pipeline that uses the OpenAILLM class to generate text. The Pipeline will load a dataset that contains a column named prompt from the Hugging Face Hub via the step LoadDataFromHub and then use the OpenAILLM class to generate text based on the dataset using the TextGeneration task.

from distilabel.llms import OpenAILLM
from distilabel.pipeline import Pipeline
from distilabel.steps import LoadDataFromHub
from distilabel.steps.tasks import TextGeneration

with Pipeline(  # 
We define a Pipeline with the name simple-text-generation-pipeline and a description A simple text generation pipeline. Note that the name is mandatory and will be used to calculate the cache signature path, so changing the name will change the cache path and will be identified as a different pipeline.

    name="simple-text-generation-pipeline",
    description="A simple text generation pipeline",
) as pipeline:  # 
We are using the Pipeline context manager, meaning that every Step subclass that is defined within the context manager will be added to the pipeline automatically.

    load_dataset = LoadDataFromHub(  # 
We define a LoadDataFromHub step named load_dataset that will load a dataset from the Hugging Face Hub, as provided via runtime parameters in the pipeline.run method below, but it can also be defined within the class instance via the arg repo_id=.... This step will basically produce output batches with the rows from the dataset, and the column prompt will be mapped to the instruction field.

        name="load_dataset",
        output_mappings={"prompt": "instruction"},
    )

    text_generation = TextGeneration(  # 
We define a TextGeneration task named text_generation that will generate text based on the instruction field from the dataset. This task will use the OpenAILLM class with the model gpt-3.5-turbo.

        name="text_generation",
        llm=OpenAILLM(model="gpt-3.5-turbo"),  # 
We define the OpenAILLM class with the model gpt-3.5-turbo that will be used by the TextGeneration task. In this case, since the OpenAILLM is used, we assume that the OPENAI_API_KEY environment variable is set, and the OpenAI API will be used to generate the text.

    )

    load_dataset >> text_generation  # 
We connect the load_dataset step to the text_generation task using the rshift operator, meaning that the output from the load_dataset step will be used as input for the text_generation task.


if __name__ == "__main__":
    distiset = pipeline.run(  # 
We run the pipeline with the parameters for the load_dataset and text_generation steps. The load_dataset step will use the repository distilabel-internal-testing/instruction-dataset-mini and the test split, and the text_generation task will use the generation_kwargs with the temperature set to 0.7 and the max_new_tokens set to 512.

        parameters={
            load_dataset.name: {
                "repo_id": "distilabel-internal-testing/instruction-dataset-mini",
                "split": "test",
            },
            text_generation.name: {
                "llm": {
                    "generation_kwargs": {
                        "temperature": 0.7,
                        "max_new_tokens": 512,
                    }
                }
            },
        },
    )
    distiset.push_to_hub(repo_id="distilabel-example")  # 
Optionally, we can push the generated Distiset to the Hugging Face Hub repository distilabel-example. This will allow you to share the generated dataset with others and use it in other pipelines.

Minimal example¶

distilabel gives a lot of flexibility to create your pipelines, but to start right away, you can omit a lot of the details and let default values:

from distilabel.llms import InferenceEndpointsLLM
from distilabel.pipeline import Pipeline
from distilabel.steps.tasks import TextGeneration
from datasets import load_dataset


dataset = load_dataset("distilabel-internal-testing/instruction-dataset-mini", split="test")

with Pipeline() as pipeline:  # 
The Pipeline can take no arguments and generate a default name on it's own that will be tracked internally.

    TextGeneration(llm=InferenceEndpointsLLM(model_id="meta-llama/Meta-Llama-3.1-8B-Instruct"))  # 
Just as with the Pipeline, the Steps don't explicitly need a name.



if __name__ == "__main__":    
    distiset = pipeline.run(dataset=dataset)  # 
You can generate the dataset as you would normally do with Hugging Face and pass the dataset to the run method.

    distiset.push_to_hub(repo_id="distilabel-example")