From 505c4fcd426e79005cf0fdc99a9cc480c18d6c9f Mon Sep 17 00:00:00 2001 From: Daniel Rosel Date: Fri, 28 Nov 2025 13:56:44 +0100 Subject: [PATCH] fix: fixing import structures from nonrelativistic --- experiments/procesing/__init__.py | 8 ++++---- experiments/procesing/context.py | 2 +- experiments/procesing/providers/__init__.py | 6 +++--- experiments/procesing/providers/backend.py | 2 +- experiments/procesing/providers/supabase.py | 2 +- experiments/procesing/steps/__init__.py | 16 ++++++++-------- experiments/procesing/steps/augment.py | 2 +- experiments/procesing/steps/base.py | 2 +- experiments/procesing/steps/chunk.py | 2 +- experiments/procesing/steps/demand.py | 2 +- experiments/procesing/steps/elasticity.py | 2 +- experiments/procesing/steps/fetch.py | 2 +- experiments/procesing/steps/join.py | 2 +- experiments/procesing/steps/pricing.py | 4 ++-- 14 files changed, 27 insertions(+), 27 deletions(-) diff --git a/experiments/procesing/__init__.py b/experiments/procesing/__init__.py index f5ddf61..2ea5d56 100644 --- a/experiments/procesing/__init__.py +++ b/experiments/procesing/__init__.py @@ -1,6 +1,6 @@ -from .context import PipelineContext -from .providers import DataProvider, SupabaseProvider, BackendAPIProvider -from .steps import ( +from procesing.context import PipelineContext +from procesing.providers import DataProvider, SupabaseProvider, BackendAPIProvider +from procesing.steps import ( BaseContextStep, FetchInteractionsStep, FetchPriceLogsStep, @@ -18,7 +18,7 @@ from .steps import ( FitPricingFunctionStep, PredictPricesStep, ) -from .pipelines import ( +from procesing.pipelines import ( interaction_extraction_pipeline, price_extraction_pipeline, elasticity_computation_pipeline, diff --git a/experiments/procesing/context.py b/experiments/procesing/context.py index 92e77cc..0ff5943 100644 --- a/experiments/procesing/context.py +++ b/experiments/procesing/context.py @@ -1,6 +1,6 @@ from typing import Any, Dict import pandas as pd -from .providers.base import DataProvider +from procesing.providers.base import DataProvider class PipelineContext: """ diff --git a/experiments/procesing/providers/__init__.py b/experiments/procesing/providers/__init__.py index cb7ada1..bbb5e6e 100755 --- a/experiments/procesing/providers/__init__.py +++ b/experiments/procesing/providers/__init__.py @@ -1,5 +1,5 @@ -from .base import DataProvider -from .supabase import SupabaseProvider -from .backend import BackendAPIProvider +from procesing.providers.base import DataProvider +from procesing.providers.supabase import SupabaseProvider +from procesing.providers.backend import BackendAPIProvider __all__ = ['DataProvider', 'SupabaseProvider', 'BackendAPIProvider'] diff --git a/experiments/procesing/providers/backend.py b/experiments/procesing/providers/backend.py index c1dc1a5..9767136 100755 --- a/experiments/procesing/providers/backend.py +++ b/experiments/procesing/providers/backend.py @@ -2,7 +2,7 @@ import os import pandas as pd import requests from typing import List -from .base import DataProvider +from procesing.providers.base import DataProvider class BackendAPIProvider(DataProvider): """Concrete backend API implementation""" diff --git a/experiments/procesing/providers/supabase.py b/experiments/procesing/providers/supabase.py index 7899b81..43ce8c0 100755 --- a/experiments/procesing/providers/supabase.py +++ b/experiments/procesing/providers/supabase.py @@ -3,7 +3,7 @@ import pandas as pd import requests from typing import List from supabase import create_client, Client -from .base import DataProvider +from procesing.providers.base import DataProvider class SupabaseProvider(DataProvider): """Concrete Supabase + backend API implementation""" diff --git a/experiments/procesing/steps/__init__.py b/experiments/procesing/steps/__init__.py index cd0c98c..6fa8779 100755 --- a/experiments/procesing/steps/__init__.py +++ b/experiments/procesing/steps/__init__.py @@ -1,11 +1,11 @@ -from .base import BaseContextStep -from .fetch import FetchInteractionsStep, FetchPriceLogsStep, FetchExperimentsStep -from .join import JoinExperimentsStep -from .augment import CreatePriceBucketsStep, AugmentEventNamesStep -from .chunk import ChunkByTimeWindowStep -from .demand import ComputeDemandStep, ComputeDemandForChunksStep -from .elasticity import AggregatePriceLogsStep, ComputeElasticityStep -from .pricing import StateSpace, BuildStateSpaceStep, FitPricingFunctionStep, PredictPricesStep +from procesing.steps.base import BaseContextStep +from procesing.steps.fetch import FetchInteractionsStep, FetchPriceLogsStep, FetchExperimentsStep +from procesing.steps.join import JoinExperimentsStep +from procesing.steps.augment import CreatePriceBucketsStep, AugmentEventNamesStep +from procesing.steps.chunk import ChunkByTimeWindowStep +from procesing.steps.demand import ComputeDemandStep, ComputeDemandForChunksStep +from procesing.steps.elasticity import AggregatePriceLogsStep, ComputeElasticityStep +from procesing.steps.pricing import StateSpace, BuildStateSpaceStep, FitPricingFunctionStep, PredictPricesStep __all__ = [ 'BaseContextStep', diff --git a/experiments/procesing/steps/augment.py b/experiments/procesing/steps/augment.py index 3eb8e2c..a8b6506 100755 --- a/experiments/procesing/steps/augment.py +++ b/experiments/procesing/steps/augment.py @@ -1,6 +1,6 @@ import numpy as np import pandas as pd -from .base import BaseContextStep +from procesing.steps.base import BaseContextStep class CreatePriceBucketsStep(BaseContextStep): """Create price bucket labels from price data""" diff --git a/experiments/procesing/steps/base.py b/experiments/procesing/steps/base.py index 92996da..054b777 100755 --- a/experiments/procesing/steps/base.py +++ b/experiments/procesing/steps/base.py @@ -1,6 +1,6 @@ from abc import ABC, abstractmethod from sklearn.base import BaseEstimator, TransformerMixin -from ..context import PipelineContext +from procesing.context import PipelineContext class BaseContextStep(BaseEstimator, TransformerMixin, ABC): """ diff --git a/experiments/procesing/steps/chunk.py b/experiments/procesing/steps/chunk.py index 8f12c8b..6877599 100755 --- a/experiments/procesing/steps/chunk.py +++ b/experiments/procesing/steps/chunk.py @@ -1,5 +1,5 @@ import pandas as pd -from .base import BaseContextStep +from procesing.steps.base import BaseContextStep class ChunkByTimeWindowStep(BaseContextStep): """ diff --git a/experiments/procesing/steps/demand.py b/experiments/procesing/steps/demand.py index 939b049..2f84985 100755 --- a/experiments/procesing/steps/demand.py +++ b/experiments/procesing/steps/demand.py @@ -1,5 +1,5 @@ import pandas as pd -from .base import BaseContextStep +from procesing.steps.base import BaseContextStep class ComputeDemandStep(BaseContextStep): """ diff --git a/experiments/procesing/steps/elasticity.py b/experiments/procesing/steps/elasticity.py index 0839b8a..d65bc43 100755 --- a/experiments/procesing/steps/elasticity.py +++ b/experiments/procesing/steps/elasticity.py @@ -1,7 +1,7 @@ import numpy as np import pandas as pd from typing import Dict, List -from .base import BaseContextStep +from procesing.steps.base import BaseContextStep class AggregatePriceLogsStep(BaseContextStep): """ diff --git a/experiments/procesing/steps/fetch.py b/experiments/procesing/steps/fetch.py index c63b0da..cde2b55 100755 --- a/experiments/procesing/steps/fetch.py +++ b/experiments/procesing/steps/fetch.py @@ -1,5 +1,5 @@ import pandas as pd -from .base import BaseContextStep +from procesing.steps.base import BaseContextStep class FetchInteractionsStep(BaseContextStep): """Fetch raw interaction data from Kafka topic""" diff --git a/experiments/procesing/steps/join.py b/experiments/procesing/steps/join.py index 9af9674..5567f0f 100755 --- a/experiments/procesing/steps/join.py +++ b/experiments/procesing/steps/join.py @@ -1,5 +1,5 @@ import pandas as pd -from .base import BaseContextStep +from procesing.steps.base import BaseContextStep class JoinExperimentsStep(BaseContextStep): """Join experiment metadata to interactions""" diff --git a/experiments/procesing/steps/pricing.py b/experiments/procesing/steps/pricing.py index 1d7c695..95f18e3 100755 --- a/experiments/procesing/steps/pricing.py +++ b/experiments/procesing/steps/pricing.py @@ -1,7 +1,7 @@ import numpy as np import pandas as pd -from .base import BaseContextStep -from ..pricing import ElasticityBasedPricingFunction +from procesing.steps.base import BaseContextStep +from procesing.pricing import ElasticityBasedPricingFunction class StateSpace: """State representation for pricing functions"""