This is the script:
import pytest
from kedro.runner.sequential_runner import SequentialRunner
from kedro.config import ConfigLoader
from src.ai4pet_tracking.pipelines.dataloader.nodes import create_dataloaders
from kedro.pipeline import Pipeline, node, pipeline
from
kedro.io import DataCatalog
from kedro.config import ConfigLoader
# Load catalog configuration from catalog.yml
conf_loader = ConfigLoader(config_file="catalog/usr/src/app/conf/base/catalog/Registration.yml")
catalog_config = conf_loader.get("catalog*")
# Create DataCatalog using the loaded catalog configuration
data_catalog = DataCatalog.from_config(catalog_config)
# Define your pipeline
def create_pipeline(data_catalog, **kwargs):
return Pipeline([
node(
func=create_dataloaders,
inputs=...
# Add more nodes as needed
])
test_pipeline = create_pipeline(data_catalog)