or run

tessl search
Log in

Version

Workspace
tessl
Visibility
Public
Created
Last updated
Describes
pypipkg:pypi/kedro@1.1.x

evals

scenario-17

rubric.jsontask.md
tile.json

tessl/pypi-kedro

tessl install tessl/pypi-kedro@1.1.0

Kedro helps you build production-ready data and analytics pipelines

Agent Success

Agent success rate when using this tile

98%

Improvement

Agent success rate improvement when using this tile compared to baseline

1.32x

Baseline

Agent success rate without this tile

74%

task.mdevals/scenario-17/

Data Processing Pipeline Builder

Build a data processing pipeline system that transforms customer order data through multiple stages. The system should handle data cleaning, enrichment, and aggregation steps.

Capabilities

Pipeline Construction

Create a pipeline with multiple processing stages that:

  • Cleans raw order data by removing invalid entries
  • Enriches orders with customer information
  • Calculates order statistics
  • Generates summary reports

Node Composition

  • The clean_orders function processes raw data and returns cleaned orders @test
  • The enrich_orders function combines cleaned orders with customer data to produce enriched orders @test
  • The calculate_stats function computes statistics from enriched orders @test
  • The generate_report function creates a summary from statistics @test

Pipeline Assembly

  • A complete pipeline connects all nodes with automatic dependency resolution @test
  • The pipeline correctly identifies all required inputs: raw_orders and customer_data @test
  • The pipeline correctly identifies the final output: report @test

Pipeline Composition

  • Two partial pipelines (cleaning + enrichment, and stats + reporting) can be combined into one complete pipeline @test

Implementation

@generates

API

def clean_orders(raw_orders):
    """
    Remove invalid entries from raw order data.

    Args:
        raw_orders: List of raw order dictionaries

    Returns:
        List of cleaned order dictionaries
    """
    pass

def enrich_orders(cleaned_orders, customer_data):
    """
    Enrich orders with customer information.

    Args:
        cleaned_orders: List of cleaned order dictionaries
        customer_data: Dictionary mapping customer IDs to customer info

    Returns:
        List of enriched order dictionaries
    """
    pass

def calculate_stats(enriched_orders):
    """
    Calculate statistics from enriched orders.

    Args:
        enriched_orders: List of enriched order dictionaries

    Returns:
        Dictionary containing order statistics
    """
    pass

def generate_report(order_stats):
    """
    Generate a summary report from statistics.

    Args:
        order_stats: Dictionary containing order statistics

    Returns:
        String containing the summary report
    """
    pass

def create_data_pipeline():
    """
    Create a complete data processing pipeline.

    Returns:
        A pipeline object that processes raw orders through all stages
    """
    pass

def create_partial_pipelines():
    """
    Create two partial pipelines and combine them.

    Returns:
        A tuple of (pipeline1, pipeline2, combined_pipeline)
    """
    pass

Dependencies { .dependencies }

kedro { .dependency }

Provides pipeline construction and composition capabilities.