Add default name for a pipeline

src/distilabel/pipeline/base.py

@@ -18,6 +18,7 @@
 import signal
 import threading
 import time
+import uuid
 from abc import ABC, abstractmethod
 from pathlib import Path
 from typing import (
@@ -158,7 +159,7 @@ class BasePipeline(ABC, RequirementsMixin, _Serializable):
 
     def __init__(
         self,
-        name: str,
+        name: Optional[str] = None,
         description: Optional[str] = None,
         cache_dir: Optional[Union[str, "PathLike"]] = None,
         enable_metadata: bool = False,
@@ -167,7 +168,7 @@ def __init__(
         """Initialize the `BasePipeline` instance.
 
         Args:
-            name: The name of the pipeline.
+            name: The name of the pipeline. If not generated, a random one will be generated by default.
             description: A description of the pipeline. Defaults to `None`.
             cache_dir: A directory where the pipeline will be cached. Defaults to `None`.
             enable_metadata: Whether to include the distilabel metadata column for the pipeline
@@ -178,7 +179,7 @@ def __init__(
                 Defaults to `None`, but can be helpful to inform in a pipeline to be shared
                 that this requirements must be installed.
         """
-        self.name = name
+        self.name = name or f"pipeline_{str(uuid.uuid4())[:8]}"
         self.description = description
         self._enable_metadata = enable_metadata
         self.dag = DAG()

tests/unit/pipeline/test_base.py

@@ -1150,6 +1150,15 @@ def process(self, inputs: StepInput) -> StepOutput:  # type: ignore
                 gen_step >> step1_0 >> step2
             pipeline.run()
 
+    def test_optional_name(self):
+        import random
+
+        random.seed(42)
+        with DummyPipeline() as pipeline:
+            name = pipeline.name
+            assert name.startswith("pipeline")
+            assert len(name.split("_")[-1]) == 8
+
 
 class TestPipelineSerialization:
     @pytest.mark.parametrize(